Repository: activemq Updated Branches: refs/heads/trunk 140ce1bc8 -> b5581166b
https://issues.apache.org/jira/browse/AMQ-5182 - apply patch from colin mondesir with thanks Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/b5581166 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/b5581166 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/b5581166 Branch: refs/heads/trunk Commit: b5581166be0eb2ccf66ad16ad521351d0169db47 Parents: 140ce1b Author: gtully <[email protected]> Authored: Tue Oct 7 15:11:31 2014 +0100 Committer: gtully <[email protected]> Committed: Tue Oct 7 15:11:31 2014 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/activemq/web/AjaxListener.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/b5581166/activemq-web/src/main/java/org/apache/activemq/web/AjaxListener.java ---------------------------------------------------------------------- diff --git a/activemq-web/src/main/java/org/apache/activemq/web/AjaxListener.java b/activemq-web/src/main/java/org/apache/activemq/web/AjaxListener.java index 4c9a8c0..6d355c2 100644 --- a/activemq-web/src/main/java/org/apache/activemq/web/AjaxListener.java +++ b/activemq-web/src/main/java/org/apache/activemq/web/AjaxListener.java @@ -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();
