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