diff options
Diffstat (limited to 'java/client/src/main')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java index 52cc70a37a..5ea2e66b35 100644 --- a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java @@ -117,8 +117,8 @@ public class AMQProtocolSession implements AMQProtocolWriter, ProtocolVersionLis _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)); + _channelId2RequestMgrMap.put(0, new RequestManager(0, this, false)); + _channelId2ResponseMgrMap.put(0, new ResponseManager(0, _stateManager, this, false)); } public AMQProtocolSession(AMQProtocolHandler protocolHandler, IoSession protocolSession, AMQConnection connection) @@ -130,8 +130,8 @@ public class AMQProtocolSession implements AMQProtocolWriter, ProtocolVersionLis _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)); + _channelId2RequestMgrMap.put(0, new RequestManager(0, this, false)); + _channelId2ResponseMgrMap.put(0, new ResponseManager(0, _stateManager, this, false)); } public AMQProtocolSession(AMQProtocolHandler protocolHandler, IoSession protocolSession, AMQConnection connection, AMQStateManager stateManager) @@ -145,8 +145,8 @@ public class AMQProtocolSession implements AMQProtocolWriter, ProtocolVersionLis _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)); + _channelId2RequestMgrMap.put(0, new RequestManager(0, this, false)); + _channelId2ResponseMgrMap.put(0, new ResponseManager(0, _stateManager, this, false)); } public void init() @@ -377,12 +377,12 @@ public class AMQProtocolSession implements AMQProtocolWriter, ProtocolVersionLis // Add request and response handlers, one per channel, if they do not already exist if (_channelId2RequestMgrMap.get(channelId) == null) { - _channelId2RequestMgrMap.put(channelId, new RequestManager(channelId, this)); + _channelId2RequestMgrMap.put(channelId, new RequestManager(channelId, this, false)); } if (_channelId2ResponseMgrMap.get(channelId) == null) { - _channelId2ResponseMgrMap.put(channelId, new ResponseManager(channelId, _stateManager, this)); + _channelId2ResponseMgrMap.put(channelId, new ResponseManager(channelId, _stateManager, this, false)); } } |