diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-22 14:53:43 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-22 14:53:43 +0000 |
| commit | 210aacb8d90319e0a643836fc55a6717f54ddb05 (patch) | |
| tree | 0aa0a64dbe7a44b18953273ab7fe6821b325959e /java/client/src | |
| parent | 1afc480c103f3e9de3f468c0203cfa4bcfa67168 (diff) | |
| download | qpid-python-210aacb8d90319e0a643836fc55a6717f54ddb05.tar.gz | |
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
Diffstat (limited to 'java/client/src')
| -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)); } } |