From f9a384b8b869c90a8e906d57d19d0aeb0dcf88f2 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 1 May 2014 13:11:57 +0000 Subject: QPID-5673 : Allow for closing of a connection that has not yet been opened git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1591649 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java | 2 ++ 1 file changed, 2 insertions(+) (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 5c54497b66..ea7c61e4ab 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 @@ -411,6 +411,8 @@ public class ConnectionEndpoint implements DescribedTypeConstructorRegistry.Sour switch (_state) { case UNOPENED: + sendOpen((short)0,0); + sendClose(close); _state = ConnectionState.CLOSED; break; case AWAITING_OPEN: -- cgit v1.2.1