From 62899dd473d48f6fb3e93aa65bd9a43770460a70 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Mon, 10 Oct 2011 20:14:51 +0000 Subject: 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 and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1181204 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'java') 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) -- cgit v1.2.1