svn commit: r661287 - /incubator/qpid/branches/broker-queue-refactor/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java

[rgodfrey]

Author: rgodfrey
Date: Thu May 29 03:37:13 2008
New Revision: 661287

URL: http://svn.apache.org/viewvc?rev=661287&view=rev
Log:
Deliver async per subscription; not queue

Modified:
    
incubator/qpid/branches/broker-queue-refactor/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java

Modified: 
incubator/qpid/branches/broker-queue-refactor/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/broker-queue-refactor/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java?rev=661287&r1=661286&r2=661287&view=diff
==============================================================================
--- 
incubator/qpid/branches/broker-queue-refactor/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
 (original)
+++ 
incubator/qpid/branches/broker-queue-refactor/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
 Thu May 29 03:37:13 2008
@@ -59,6 +59,7 @@
 import java.util.HashMap;
 import java.util.LinkedHashMap;
 import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicInteger;
 
 public class AMQChannel
 {
@@ -818,7 +819,6 @@
     }
 
 
-
     public void setSuspended(boolean suspended)
     {
 
@@ -828,17 +828,12 @@
         {
             if (wasSuspended)
             {
-                _log.debug("Unsuspending channel " + this);
                 // may need to deliver queued messages
                 for (Subscription s : _tag2SubscriptionMap.values())
                 {
-                    s.getQueue().deliverAsync();
+                    s.getQueue().deliverAsync(s);
                 }
             }
-            else
-            {
-                _log.debug("Suspending channel " + this);
-            }
         }
     }