You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2014/10/07 16:12:02 UTC
git commit: https://issues.apache.org/jira/browse/AMQ-5182 - apply
patch from colin mondesir with thanks
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 <ga...@gmail.com>
Authored: Tue Oct 7 15:11:31 2014 +0100
Committer: gtully <ga...@gmail.com>
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();