summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2008-08-11 11:15:42 +0000
committerMartin Ritchie <ritchiem@apache.org>2008-08-11 11:15:42 +0000
commitcb40642eaf5d9eb032bc596a3fa79c1f068cd5a1 (patch)
tree19162298810778db88b0bdfd9d2b19a5f3267ae6
parent3e8faeb0b9c2af4a613587f2d7cf6617dcf26aaf (diff)
downloadqpid-python-cb40642eaf5d9eb032bc596a3fa79c1f068cd5a1.tar.gz
QPID-1223 : Updated AckTest to correctly create and close the ApplicationRegistry
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@684713 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java9
1 files changed, 3 insertions, 6 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java b/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java
index d65a431a2a..09d83bde0c 100644
--- a/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java
@@ -60,20 +60,17 @@ public class AckTest extends TestCase
private StoreContext _storeContext = new StoreContext();
- private AMQChannel _channel;
+ private AMQChannel _channel;
private AMQQueue _queue;
private static final AMQShortString DEFAULT_CONSUMER_TAG = new AMQShortString("conTag");
- public AckTest() throws Exception
- {
- ApplicationRegistry.initialise(new NullApplicationRegistry());
- }
-
protected void setUp() throws Exception
{
super.setUp();
+ ApplicationRegistry.initialise(new NullApplicationRegistry(), 1);
+
_messageStore = new TestMemoryMessageStore();
_protocolSession = new MockProtocolSession(_messageStore);
_channel = new AMQChannel(_protocolSession,5, _messageStore /*dont need exchange registry*/);