[hornetq-commits] JBoss hornetq SVN: r9895 - branches/Branch_New_Paging_preMerge/tests/src/org/hornetq/tests/integration/jms/server/management.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-11-16 15:11:51 -0500 (Tue, 16 Nov 2010)
New Revision: 9895

Modified:
   branches/Branch_New_Paging_preMerge/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java
Log:
fixing test

Modified: branches/Branch_New_Paging_preMerge/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java
===================================================================
--- branches/Branch_New_Paging_preMerge/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java	2010-11-16 16:34:05 UTC (rev 9894)
+++ branches/Branch_New_Paging_preMerge/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControl2Test.java	2010-11-16 20:11:51 UTC (rev 9895)
@@ -359,6 +359,8 @@
 
       System.out.println("queueName is: " + queueName);
       
+      Connection connection = null;
+      
       try
       {
          startHornetQServer(NettyAcceptorFactory.class.getName());
@@ -372,7 +374,7 @@
          ConnectionFactory cf1 = JMSUtil.createFactory(NettyConnectorFactory.class.getName(),
                                                        JMSServerControl2Test.CONNECTION_TTL,
                                                        JMSServerControl2Test.PING_PERIOD);
-         Connection connection = cf1.createConnection();
+         connection = cf1.createConnection();
          Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
          
          MessageProducer producer = session.createProducer(queue);
@@ -408,6 +410,7 @@
          
          assertTrue(sessInfos.length > 0);
          boolean lastMsgFound = false;
+         Thread.sleep(1000);
          for (JMSSessionInfo sInfo : sessInfos)
          {
             System.out.println("Session name: " + sInfo.getSessionID());
@@ -434,11 +437,23 @@
       }
       finally
       {
-         if (serverManager != null)
+         try
          {
-            serverManager.destroyQueue(queueName);
-            serverManager.stop();
+            if (connection != null)
+            {
+               connection.close();
+            }
+            
+            if (serverManager != null)
+            {
+               serverManager.destroyQueue(queueName);
+               serverManager.stop();
+            }
          }
+         catch (Throwable ignored)
+         {
+            ignored.printStackTrace();
+         }
 
          if (server != null)
          {