diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2008-08-21 09:32:02 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2008-08-21 09:32:02 +0000 |
| commit | ab33f5c5804a4162766a8c8a41fd410507f48d98 (patch) | |
| tree | 061f097b0b207d9246f7f08f1a5167c24998519e /java/client/src | |
| parent | 74bc9ffe9db4cc43fc761bf0ca1a50a5c409476c (diff) | |
| download | qpid-python-ab33f5c5804a4162766a8c8a41fd410507f48d98.tar.gz | |
QPID-1225 : Temporary commit to allow CI systems to help diagnose cause of race condition. My guess is that the session is open but closes right after the isClosed call is done. So the client the goes on and does a waitForFrame that never arrives causing the timeout exceptions. As commented in AMQPH if we add our frame listener such that it will receive any existing and subsequent exceptions, such as connection closing whilst we add them to the framelisteners then I think this will resolve the issue.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@687664 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java index e92817f713..25439aba94 100644 --- a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java +++ b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java @@ -658,6 +658,8 @@ public class AMQProtocolHandler extends IoHandlerAdapter } _frameListeners.add(listener); + //FIXME: At this point here we should check or before add we should check _stateManager is in an open + // state so as we don't check we are likely just to time out here as I believe is being seen in QPID-1255 } _protocolSession.writeFrame(frame); |