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 4c9a8c0c62..6d355c2d5a 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();