From 616c55cbeb855e9fbf7c10906be2ff3e621caf0e Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Mon, 27 Jan 2014 10:40:31 +0000 Subject: QPID-5514: [Java Broker Management] Close the AMQP transport on deletion of the port too. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1561631 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/server/model/adapter/PortAdapter.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'qpid/java/broker-core') diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/PortAdapter.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/PortAdapter.java index 3e7d03b5ac..882335626d 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/PortAdapter.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/model/adapter/PortAdapter.java @@ -311,7 +311,11 @@ public class PortAdapter extends AbstractAdapter implements Port { if (state == State.INITIALISING || state == State.ACTIVE || state == State.STOPPED || state == State.QUIESCED || state == State.ERRORED) { - return _state.compareAndSet(state, State.DELETED); + if( _state.compareAndSet(state, State.DELETED)) + { + onStop(); + return true; + } } else { -- cgit v1.2.1