From 176675ef4914dbc548e92700232ec4429614430a Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 12 Feb 2015 18:24:35 +0000 Subject: QPID-6386 : [AMQP 1.0 Common] close the sender if the TCP connection is terminated before connection.open has occurred git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1659348 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java | 1 + 1 file changed, 1 insertion(+) (limited to 'qpid/java') diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java index 766c9705a1..17f334153d 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java @@ -457,6 +457,7 @@ public class ConnectionEndpoint implements DescribedTypeConstructorRegistry.Sour case AWAITING_OPEN: case CLOSE_SENT: _state = ConnectionState.CLOSED; + closeSender(); break; case OPEN: _state = ConnectionState.CLOSE_RECEIVED; -- cgit v1.2.1