From 210aacb8d90319e0a643836fc55a6717f54ddb05 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Mon, 22 Jan 2007 14:53:43 +0000 Subject: Improvements to debugging messages from Request/ResponseManager. Added timed wait for Channel.CloseOk massage in broker's closeChannelRequest method. Added checks for illegal frames that would open a closed channel git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@498631 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/client/protocol/AMQProtocolSession.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) (limited to 'java/client') 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)); } } -- cgit v1.2.1