1 files changed, 8 insertions, 5 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java
index 2092e17858..59237f8c69 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java
@@ -622,11 +622,6 @@ public class Connection extends ConnectionInvoker
         close(ConnectionCloseCode.NORMAL, null);
     }
 
-    public void mgmtClose()
-    {
-        close(ConnectionCloseCode.CONNECTION_FORCED, "The connection was closed using the broker's management interface.");
-    }
-
 
     protected void sendConnectionClose(ConnectionCloseCode replyCode, String replyText, Option ... _options)
     {
@@ -875,4 +870,12 @@ public class Connection extends ConnectionInvoker
         _redirecting.set(redirecting);
     }
 
+    public boolean isClosing()
+    {
+        synchronized (lock)
+        {
+            return state == CLOSING || state == CLOSED;
+        }
+    }
+
 }