summaryrefslogtreecommitdiff
path: root/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java
diff options
context:
space:
mode:
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.java10
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