From 35e088856d752debe99701e48654c24c6ac97422 Mon Sep 17 00:00:00 2001 From: James Strachan Date: Tue, 28 Feb 2006 09:49:25 +0000 Subject: [PATCH] added comment - I'd have thought a Map was better? git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@381612 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/activemq/ActiveMQSessionExecutor.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java index 6a30f1f8f4..af3dda84ef 100755 --- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java +++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java @@ -86,6 +86,9 @@ public class ActiveMQSessionExecutor implements Task { } void dispatch(MessageDispatch message){ + + // TODO - we should use a Map for this indexed by consumerId + for (Iterator i = this.session.consumers.iterator(); i.hasNext();) { ActiveMQMessageConsumer consumer = (ActiveMQMessageConsumer) i.next(); ConsumerId consumerId = message.getConsumerId();