From 405e7cf92aa57b3952563b15c64162b647baa5ac Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Mon, 6 Feb 2012 14:41:53 +0000 Subject: QPID-3756: Reorder Java Broker's connection close process so that ConnectionCloseOk is sent only after first updating its internal state. This change means that the connection mbean will be deregistered from JMX before sending ConnectionCloseOk, thus removing the possibility of the race condition. The client side process is unaffected by this change. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1241024 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/transport/Connection.java | 2 +- .../main/java/org/apache/qpid/transport/ConnectionDelegate.java | 9 +++++++-- 2 files changed, 8 insertions(+), 3 deletions(-) (limited to 'java/common/src') diff --git a/java/common/src/main/java/org/apache/qpid/transport/Connection.java b/java/common/src/main/java/org/apache/qpid/transport/Connection.java index fbf53996a8..b0f1a1bad8 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Connection.java +++ b/java/common/src/main/java/org/apache/qpid/transport/Connection.java @@ -512,7 +512,7 @@ public class Connection extends ConnectionInvoker exception(new ConnectionException(t)); } - void closeCode(ConnectionClose close) + public void closeCode(ConnectionClose close) { synchronized (lock) { diff --git a/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java b/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java index c70cab85c9..fdd35d49ef 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java +++ b/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java @@ -71,12 +71,17 @@ public abstract class ConnectionDelegate @Override public void connectionClose(Connection conn, ConnectionClose close) { - conn.connectionCloseOk(); - conn.getSender().close(); + sendConnectionCloseOkAndCloseSender(conn); conn.closeCode(close); conn.setState(CLOSE_RCVD); } + protected void sendConnectionCloseOkAndCloseSender(Connection conn) + { + conn.connectionCloseOk(); + conn.getSender().close(); + } + @Override public void connectionCloseOk(Connection conn, ConnectionCloseOk ok) { conn.getSender().close(); -- cgit v1.2.1