From 6ed29f676736ba8599d8e087cbc49aff30396e2e Mon Sep 17 00:00:00 2001 From: Aidan Skinner Date: Wed, 25 Feb 2009 14:00:39 +0000 Subject: 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 --- .../apache/qpid/server/queue/SimpleAMQQueueThreadPoolTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'java') 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 { -- cgit v1.2.1