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: [email protected]
For additional commands, e-mail: [email protected]
