https://issues.apache.org/jira/browse/AMQ-5182 - apply patch from colin mondesir with thanks

This commit is contained in:
gtully 2014-10-07 15:11:31 +01:00
parent 140ce1bc8f
commit b5581166be
1 changed files with 1 additions and 1 deletions

View File

@ -65,7 +65,7 @@ public class AjaxListener implements MessageAvailableListener {
Message message = consumer.receive(10);
LOG.debug("message is " + message);
if (message != null) {
if (!continuation.isResumed() && !continuation.isInitial()) {
if (!continuation.isResumed()) {
LOG.debug("Resuming suspended continuation {}", continuation);
continuation.setAttribute("undelivered_message", new UndeliveredAjaxMessage(message, consumer));
continuation.resume();