Connection close is now performed by i/o thread

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1660909 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 36 insertions, 7 deletions

diff --git a/qpid/java/systests/src/test/java/org/apache/qpid/client/AsynchMessageListenerTest.java b/qpid/java/systests/src/test/java/org/apache/qpid/client/AsynchMessageListenerTest.java
index a13bf71d5e..74b1f8a572 100644
--- a/qpid/java/systests/src/test/java/org/apache/qpid/client/AsynchMessageListenerTest.java
+++ b/qpid/java/systests/src/test/java/org/apache/qpid/client/AsynchMessageListenerTest.java
@@ -70,6 +70,9 @@ public class AsynchMessageListenerTest extends QpidBrokerTestCase
 
     }
 
+
+
+
     public void testMessageListener() throws Exception
     {
         CountingMessageListener countingMessageListener = new CountingMessageListener(MSG_COUNT);
diff --git a/qpid/java/systests/src/test/java/org/apache/qpid/systest/management/jmx/ConnectionManagementTest.java b/qpid/java/systests/src/test/java/org/apache/qpid/systest/management/jmx/ConnectionManagementTest.java
index 67af3e17e4..ee9f2070d3 100644
--- a/qpid/java/systests/src/test/java/org/apache/qpid/systest/management/jmx/ConnectionManagementTest.java
+++ b/qpid/java/systests/src/test/java/org/apache/qpid/systest/management/jmx/ConnectionManagementTest.java
@@ -23,13 +23,7 @@ import java.util.Date;
 import java.util.Iterator;
 import java.util.List;
 
-import javax.jms.Connection;
-import javax.jms.Destination;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.Queue;
-import javax.jms.Session;
+import javax.jms.*;
 import javax.management.JMException;
 import javax.management.openmbean.CompositeData;
 import javax.management.openmbean.CompositeDataSupport;
@@ -74,6 +68,38 @@ public class ConnectionManagementTest extends QpidBrokerTestCase
         }
     }
 
+    public void testManagementClosesConnection() throws Exception
+    {
+        assertEquals("Expected no managed connections", 0, getManagedConnections().size());
+
+        _connection = getConnection();
+        assertEquals("Expected one managed connection", 1, getManagedConnections().size());
+
+
+        ManagedConnection managedConnection = getManagedConnections().get(0);
+
+        managedConnection.closeConnection();
+
+        assertEquals("Expected no managed connections", 0, getManagedConnections().size());
+
+        /*
+        try
+        {
+
+            _connection.start();
+            fail("Exception not thrown");
+        }
+        catch (javax.jms.IllegalStateException ise)
+        {
+            ise.printStackTrace();
+            // PASS
+        }*/
+
+    }
+
+
+
+
     public void testNumberOfManagedConnectionsMatchesNumberOfClientConnections() throws Exception
     {
         assertEquals("Expected no managed connections", 0, getManagedConnections().size());