Author: robbie Date: Mon Oct 10 20:14:51 2011 New Revision: 1181204 URL: http://svn.apache.org/viewvc?rev=1181204&view=rev Log: 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<[email protected]> and myself. Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java?rev=1181204&r1=1181203&r2=1181204&view=diff ============================================================================== --- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java (original) +++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java Mon Oct 10 20:14:51 2011 @@ -362,7 +362,7 @@ public class AMQProtocolSession implemen public void closeProtocolSession() throws AMQException { - _protocolHandler.closeConnection(0); + _protocolHandler.getNetworkConnection().close(); } public void failover(String host, int port) --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
