diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2015-02-12 18:24:35 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2015-02-12 18:24:35 +0000 |
| commit | 176675ef4914dbc548e92700232ec4429614430a (patch) | |
| tree | d138705307cc120931a3db344278ad327131feaf /qpid/java | |
| parent | 822ef8b38a63e3b351b30c382bfc77de39904c77 (diff) | |
| download | qpid-python-176675ef4914dbc548e92700232ec4429614430a.tar.gz | |
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
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java | 1 |
1 files changed, 1 insertions, 0 deletions
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; |