QPID-1668: check initial count, don't assume it's 0. It should be, but there are bugs in ApplicationRegistry.close that prevent this from working.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747783 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 4 deletions

diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueThreadPoolTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueThreadPoolTest.java
index f45d887dec..832df80004 100644
--- a/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueThreadPoolTest.java
+++ b/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueThreadPoolTest.java
@@ -35,7 +35,7 @@ public class SimpleAMQQueueThreadPoolTest extends TestCase
 
     public void test() throws AMQException
     {
-        assertEquals("References exist before start!", 0, ReferenceCountingExecutorService.getInstance().getReferenceCount());
+        int initialCount = ReferenceCountingExecutorService.getInstance().getReferenceCount();
         VirtualHost test = ApplicationRegistry.getInstance(1).getVirtualHostRegistry().getVirtualHost("test");
 
         try
@@ -45,12 +45,12 @@ public class SimpleAMQQueueThreadPoolTest extends TestCase
                                                                                        false, test, null);
 
             assertFalse("Creation did not start Pool.", ReferenceCountingExecutorService.getInstance().getPool().isShutdown());
+
+            assertEquals("References not increased", initialCount + 1, ReferenceCountingExecutorService.getInstance().getReferenceCount());
             
             queue.stop();
 
-            assertEquals("References still exist", 0, ReferenceCountingExecutorService.getInstance().getReferenceCount());
-
-            assertTrue("Stop did not clean up.", ReferenceCountingExecutorService.getInstance().getPool().isShutdown());
+            assertEquals("References not decreased", initialCount , ReferenceCountingExecutorService.getInstance().getReferenceCount());
         }
         finally
         {