diff options
Diffstat (limited to 'java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java')
-rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java index c69ca507ef..aa6ee6ff12 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java @@ -12,6 +12,7 @@ import org.apache.qpid.server.store.TestableMemoryMessageStore; import org.apache.qpid.server.txn.NonTransactionalContext; import org.apache.qpid.server.txn.TransactionalContext; import org.apache.qpid.server.virtualhost.VirtualHost; +import org.apache.qpid.server.registry.ApplicationRegistry; import junit.framework.TestCase; @@ -56,11 +57,20 @@ public class SimpleAMQQueueTest extends TestCase protected void setUp() throws Exception { super.setUp(); + //Create Application Registry for test + ApplicationRegistry.getInstance(1); + AMQShortString qname = new AMQShortString("qname"); AMQShortString owner = new AMQShortString("owner"); _queue = new SimpleAMQQueue(qname, false, owner, false, new VirtualHost("vhost", store)); } + @Override + protected void tearDown() + { + ApplicationRegistry.remove(1); + } + public void testGetFirstMessageId() throws Exception { // Create message |