mirror of https://github.com/apache/activemq.git
commit
365c1bbe9a
|
@ -950,7 +950,9 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void afterRollback() throws Exception {
|
public void afterRollback() throws Exception {
|
||||||
|
if (LOG.isTraceEnabled()) {
|
||||||
LOG.trace("rollback {}", ack, new Throwable("here"));
|
LOG.trace("rollback {}", ack, new Throwable("here"));
|
||||||
|
}
|
||||||
// ensure we don't filter this as a duplicate
|
// ensure we don't filter this as a duplicate
|
||||||
connection.rollbackDuplicate(ActiveMQSession.this, md.getMessage());
|
connection.rollbackDuplicate(ActiveMQSession.this, md.getMessage());
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue