qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rgodf...@apache.org
Subject svn commit: r1659348 - /qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
Date Thu, 12 Feb 2015 18:24:36 GMT
Author: rgodfrey
Date: Thu Feb 12 18:24:35 2015
New Revision: 1659348

URL: http://svn.apache.org/r1659348
Log:
QPID-6386 : [AMQP 1.0 Common] close the sender if the TCP connection is terminated before
connection.open has occurred

Modified:
    qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java

Modified: qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java?rev=1659348&r1=1659347&r2=1659348&view=diff
==============================================================================
--- qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
(original)
+++ qpid/trunk/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java
Thu Feb 12 18:24:35 2015
@@ -457,6 +457,7 @@ public class ConnectionEndpoint implemen
                 case AWAITING_OPEN:
                 case CLOSE_SENT:
                     _state = ConnectionState.CLOSED;
+                    closeSender();
                     break;
                 case OPEN:
                     _state = ConnectionState.CLOSE_RECEIVED;



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message