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