You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kp...@apache.org on 2007/01/18 15:43:11 UTC

svn commit: r497450 - /incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java

Author: kpvdr
Date: Thu Jan 18 06:43:10 2007
New Revision: 497450

URL: http://svn.apache.org/viewvc?view=rev&rev=497450
Log:
Client: added request and response managers for channel 0

Modified:
    incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java

Modified: incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java?view=diff&rev=497450&r1=497449&r2=497450
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java (original)
+++ incubator/qpid/branches/qpid.0-9/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java Thu Jan 18 06:43:10 2007
@@ -114,6 +114,10 @@
         _protocolHandler = null;
         _minaProtocolSession = null;
         _stateManager = new AMQStateManager(this);
+
+        // Add channel 0 request and response managers, since they will not be added through the usual mechanism
+        _channelId2RequestMgrMap.put(0, new RequestManager(0, this));
+        _channelId2ResponseMgrMap.put(0, new ResponseManager(0, _stateManager, this));
     }
 
     public AMQProtocolSession(AMQProtocolHandler protocolHandler, IoSession protocolSession, AMQConnection connection)
@@ -123,6 +127,10 @@
         // properties of the connection are made available to the event handlers
         _minaProtocolSession.setAttribute(AMQ_CONNECTION, connection);
         _stateManager = new AMQStateManager(this);
+
+        // Add channel 0 request and response managers, since they will not be added through the usual mechanism
+        _channelId2RequestMgrMap.put(0, new RequestManager(0, this));
+        _channelId2ResponseMgrMap.put(0, new ResponseManager(0, _stateManager, this));
     }
  
     public AMQProtocolSession(AMQProtocolHandler protocolHandler, IoSession protocolSession, AMQConnection connection, AMQStateManager stateManager)
@@ -135,6 +143,9 @@
         _stateManager = stateManager;
         _stateManager.setProtocolSession(this);
                 
+        // Add channel 0 request and response managers, since they will not be added through the usual mechanism
+        _channelId2RequestMgrMap.put(0, new RequestManager(0, this));
+        _channelId2ResponseMgrMap.put(0, new ResponseManager(0, _stateManager, this));
     }
 
     public void init()