2015-02-01 3 views
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(); 
    } 
}); 

ответ

0

установить ClientSession получить в конструкторе (CreateSession ) в autoCommitSends параметров и autoCommitAcks быть получены пользователем ofyour приложения.

таким образом, вы обезвредить свой вопрос, дав волю своему пользователю принять решение о фиксаций

+0

Не совсем то, что я имел в виду, но он будет делать. – Igor

Смежные вопросы