@ -601,6 +601,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
@@ -601,6 +601,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
rollbackIfNecessary(session);
thrownewMessageRejectedWhileStoppingException();
}
try{
invokeListener(session,message);
}
@ -630,6 +631,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
@@ -630,6 +631,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
@ -731,7 +733,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
@@ -731,7 +733,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
JmsUtils.rollbackIfNecessary(session);
}
}
else{
elseif(isClientAcknowledge(session)){
session.recover();
}
}
@ -753,7 +755,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
@@ -753,7 +755,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen