From 898940f5bfe022b599398c1226e919e5bec378ed Mon Sep 17 00:00:00 2001 From: yang wei Date: Tue, 13 Feb 2018 12:44:10 +0800 Subject: [PATCH] ARTEMIS-1679 Stopping consumer no need to wait until all queued tasks done --- .../activemq/artemis/core/client/impl/ClientConsumerImpl.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java index ccaa004064..19987ff6be 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientConsumerImpl.java @@ -482,8 +482,6 @@ public final class ClientConsumerImpl implements ClientConsumerInternal { @Override public void stop(final boolean waitForOnMessage) throws ActiveMQException { - waitForOnMessageToComplete(waitForOnMessage); - if (browseOnly) { // stop shouldn't affect browser delivery return; @@ -496,6 +494,7 @@ public final class ClientConsumerImpl implements ClientConsumerInternal { stopped = true; } + waitForOnMessageToComplete(waitForOnMessage); } @Override