HornetQ 在 onMessage 之后提交 ClientSession
HornetQ commit ClientSession after onMessage
是否需要在处理传入消息后提交 ClientSession?
ClientSession session = ... ;
clientConsumer.setMessageHandler(new MessageHandler() {
@Override
public void onMessage(ClientMessage message) {
...
try {
session.commit();
} catch (HornetQException e) { }
finally {
session.close();
}
});
设置你的ClientSession进入构造函数(createSession
) 参数 autoCommitSends 和 autoCommitAcks 将被您的应用程序的用户接收。
通过这种方式,您可以让您的用户决定提交,从而中和您的问题
是否需要在处理传入消息后提交 ClientSession?
ClientSession session = ... ;
clientConsumer.setMessageHandler(new MessageHandler() {
@Override
public void onMessage(ClientMessage message) {
...
try {
session.commit();
} catch (HornetQException e) { }
finally {
session.close();
}
});
设置你的ClientSession进入构造函数(createSession ) 参数 autoCommitSends 和 autoCommitAcks 将被您的应用程序的用户接收。
通过这种方式,您可以让您的用户决定提交,从而中和您的问题