You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2011/10/10 22:14:51 UTC
svn commit: r1181204 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java
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<or...@gmail.com> 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:commits-subscribe@qpid.apache.org