From 913d1a55b290f9a8295d5e8396c696d3cee73bc0 Mon Sep 17 00:00:00 2001
From: Robert Godfrey <rgodfrey@apache.org>
Date: Thu, 19 Jun 2008 09:01:59 +0000
Subject: QPID-950 : Broker refactoring, copied / merged from branch

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@669431 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/qpid/server/handler/BasicConsumeMethodHandler.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

(limited to 'java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java')

diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java
index 7cd4afdb77..5342a7f518 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java
@@ -111,7 +111,7 @@ public class BasicConsumeMethodHandler implements StateAwareMethodListener<Basic
 
                 try
                 {
-                    AMQShortString consumerTag = channel.subscribeToQueue(consumerTagName, queue, session, !body.getNoAck(),
+                    AMQShortString consumerTag = channel.subscribeToQueue(consumerTagName, queue, !body.getNoAck(),
                                                                           body.getArguments(), body.getNoLocal(), body.getExclusive());
                     if (!body.getNowait())
                     {
@@ -121,8 +121,7 @@ public class BasicConsumeMethodHandler implements StateAwareMethodListener<Basic
 
                     }
 
-                    //now allow queue to start async processing of any backlog of messages
-                    queue.deliverAsync();
+                    
                 }
                 catch (org.apache.qpid.AMQInvalidArgumentException ise)
                 {
-- 
cgit v1.2.1