diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java index 42ecc9d6b4..07522505f8 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java @@ -1530,6 +1530,7 @@ public class Queue extends BaseDestination implements Task, UsageListener { // are we done browsing? no new messages paged if (!added) { browser.decrementQueueRef(); + browserDispatches.remove(browserDispatch); } } catch (Exception e) { LOG.warn("exception on dispatch to browser: " + browserDispatch.getBrowser(), e);