From 5401cf8365ae56a0662fb648738fca94a178d10a Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Sat, 1 Jul 2006 04:20:53 +0000 Subject: [PATCH] added some debug to see when consumers are added and removed. git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@418435 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/broker/region/AbstractRegion.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java index 6e0c05a7ea..0da34130bc 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java @@ -141,6 +141,7 @@ abstract public class AbstractRegion implements Region { } public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception { + log.debug("Adding consumer: "+info.getConsumerId()); Subscription sub = createSubscription(context, info); @@ -162,7 +163,7 @@ abstract public class AbstractRegion implements Region { } } } - + subscriptions.put(info.getConsumerId(), sub); // Add the subscription to all the matching queues. @@ -196,6 +197,8 @@ abstract public class AbstractRegion implements Region { } public void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception { + + log.debug("Removing consumer: "+info.getConsumerId()); Subscription sub = (Subscription) subscriptions.remove(info.getConsumerId()); if( sub==null )