0
Нужно ли мне фиксировать ClientSession после работы с входящим сообщением?HornetQ commit ClientSession после onMessage
ClientSession session = ... ;
clientConsumer.setMessageHandler(new MessageHandler() {
@Override
public void onMessage(ClientMessage message) {
...
try {
session.commit();
} catch (HornetQException e) { }
finally {
session.close();
}
});
Не совсем то, что я имел в виду, но он будет делать. – Igor