From 5bfbc542b1349895dff5a52408302c59323f6aa4 Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Wed, 5 Dec 2012 09:37:16 +0000 Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-4181 - remove the browser imidiatelly when finished git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1417331 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/activemq/broker/region/Queue.java | 1 + 1 file changed, 1 insertion(+) 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);