1 files changed, 9 insertions, 3 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
index c3219e6564..bba39403a5 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
@@ -182,6 +182,13 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
                 _fastAccessConsumers[i] = null;
             }
         }
+
+
+
+        public String toString()
+        {
+            return "{ Fast: " + Arrays.asList(_fastAccessConsumers) + " ; Slow: " + _slowAccessConsumers + "}";
+        }
     }
 
 
@@ -299,9 +306,6 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
      */
     private final IdToConsumerMap _consumers = new IdToConsumerMap();
 
-            //Map<AMQShortString, BasicMessageConsumer> _consumers =
-            //new ConcurrentHashMap<AMQShortString, BasicMessageConsumer>();
-
     /**
      * Contains a list of consumers which have been removed but which might still have
      * messages to acknowledge, eg in client ack or transacted modes
@@ -1419,7 +1423,9 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
         if (message.isDeliverMessage())
         {
             _highestDeliveryTag.set(message.getDeliverBody().getDeliveryTag());
+
             _queue.add(message);
+
         }
         else
         {