Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Message listener containers only call Session.recover() in client acknowledge mode

Browse Source 
Issue: SPR-13052
(cherry picked from commit c111bd7)
This commit is contained in:
Juergen Hoeller
2015-05-22 17:24:26 +02:00
parent e5ccdfb029
commit a64dcc2a31
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-jms/src/main/java/org/springframework/jms/listener/AbstractMessageListenerContainer.java
View File

@@ -63,7 +63,7 @@ import org.springframework.util.ErrorHandler;
* consider setting "sessionTransacted" to "true" instead.
* <li>"sessionAcknowledgeMode" set to "CLIENT_ACKNOWLEDGE":
* Automatic message acknowledgment <i>after</i> successful listener execution;
* no redelivery in case of exception thrown.
* best-effort redelivery in case of exception thrown.
* <li>"sessionAcknowledgeMode" set to "DUPS_OK_ACKNOWLEDGE":
* <i>Lazy</i> message acknowledgment during or after listener execution;
* <i>potential redelivery</i> in case of exception thrown.
@@ -469,6 +469,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
rollbackIfNecessary(session);
throw new MessageRejectedWhileStoppingException();
}
try {
invokeListener(session, message);
}
@@ -498,6 +499,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
@SuppressWarnings("rawtypes")
protected void invokeListener(Session session, Message message) throws JMSException {
Object listener = getMessageListener();
if (listener instanceof SessionAwareMessageListener) {
doInvokeListener((SessionAwareMessageListener) listener, session, message);
}
@@ -599,7 +601,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
JmsUtils.rollbackIfNecessary(session);
}
}
else {
else if (isClientAcknowledge(session)) {
session.recover();
}
}
@@ -621,7 +623,7 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
JmsUtils.rollbackIfNecessary(session);
}
}
else {
else if (isClientAcknowledge(session)) {
session.recover();
}
}