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
This commit is contained in:
Bosanac Dejan 2012-12-05 09:37:16 +00:00
parent db1e6d1cb7
commit 5bfbc542b1
1 changed files with 1 additions and 0 deletions

View File

@ -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);