You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2008/08/11 13:15:43 UTC
svn commit: r684713 -
/incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java
Author: ritchiem
Date: Mon Aug 11 04:15:42 2008
New Revision: 684713
URL: http://svn.apache.org/viewvc?rev=684713&view=rev
Log:
QPID-1223 : Updated AckTest to correctly create and close the ApplicationRegistry
Modified:
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java
Modified: incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java?rev=684713&r1=684712&r2=684713&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java (original)
+++ incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/AckTest.java Mon Aug 11 04:15:42 2008
@@ -60,20 +60,17 @@
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*/);