HornetQ 在 onMessage 之后提交 ClientSession

Question

是否需要在处理传入消息后提交 ClientSession？

 ClientSession session = ... ;       
 clientConsumer.setMessageHandler(new MessageHandler() {
   @Override
   public void onMessage(ClientMessage message) {
   ...
   try {
     session.commit();
   } catch (HornetQException e) { }
   finally {
     session.close();
   }
 });

Answer 1

设置你的ClientSession进入构造函数（createSession ) 参数 autoCommitSends 和 autoCommitAcks 将被您的应用程序的用户接收。

通过这种方式，您可以让您的用户决定提交，从而中和您的问题

HornetQ 在 onMessage 之后提交 ClientSession

HornetQ commit ClientSession after onMessage

java

hornetq