diff options
| author | Robert Gemmell <robbie@apache.org> | 2011-10-10 20:14:51 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2011-10-10 20:14:51 +0000 |
| commit | 62899dd473d48f6fb3e93aa65bd9a43770460a70 (patch) | |
| tree | 87ee13ccb1ac36cd47b3fc70d91fa4dbf5a577bc | |
| parent | 306fe6cd338055144ffb1bd979e003afadee755c (diff) | |
| download | qpid-python-62899dd473d48f6fb3e93aa65bd9a43770460a70.tar.gz | |
QPID-3534, QPID-3535: make 0-8/0-9/0-9-1 client path simply close the underlying NetworkConnection instead of sending an erroneous ConnectionClose body after replying to the ConnectionClose from the broker or receving an unsupported protocol verison during initial connection negotiation. Stops the client making 2 seperate attempts to initiate failover, and removes possibility of the exception that can currently cause both of them to be skipped.
Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1181204 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java | 2 |
1 files changed, 1 insertions, 1 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 a938bd47f8..a4694ce00f 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 @@ -362,7 +362,7 @@ public class AMQProtocolSession implements AMQVersionAwareProtocolSession public void closeProtocolSession() throws AMQException { - _protocolHandler.closeConnection(0); + _protocolHandler.getNetworkConnection().close(); } public void failover(String host, int port) |