With this change:
catch (RuntimeException e)
| {
| if (!transactedOrClientAck)
| {
| try
| {
|
| consumer.acknowledge(jbm.getCoreMessage(), false);
|
| session.getCoreSession().rollback();
|
| session.setRecoverCalled(true);
| }
| catch (Exception e2)
| {
| log.error("Failed to recover session", e2);
| }
| }
| }
|
the message would be sent to the ACK list on the transaction before the rollback, so the
counter would be incremented.
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4210838#...
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...