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