// Transacted session created by this container -> rollback.
JmsUtils.rollbackIfNecessary(session);
if(session.getTransacted()){
if(isSessionLocallyTransacted(session)){
// Transacted session created by this container -> rollback.
JmsUtils.rollbackIfNecessary(session);
}
}
else{
session.recover();
}
}
@ -725,12 +730,17 @@ public abstract class AbstractMessageListenerContainer
@@ -725,12 +730,17 @@ public abstract class AbstractMessageListenerContainer