1 files changed, 5 insertions, 2 deletions
diff --git a/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java b/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java
index b9b5634109..0180c2d30c 100644
--- a/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java
+++ b/java/systests/src/test/java/org/apache/qpid/server/queue/AckTest.java
@@ -32,6 +32,7 @@ import org.apache.qpid.server.ack.UnacknowledgedMessage;
 import org.apache.qpid.server.ack.UnacknowledgedMessageMap;
 import org.apache.qpid.server.registry.ApplicationRegistry;
 import org.apache.qpid.server.store.TestableMemoryMessageStore;
+import org.apache.qpid.server.store.StoreContext;
 import org.apache.qpid.server.txn.NonTransactionalContext;
 import org.apache.qpid.server.txn.TransactionalContext;
 import org.apache.qpid.server.util.TestApplicationRegistry;
@@ -53,6 +54,8 @@ public class AckTest extends TestCase
 
     private TestableMemoryMessageStore _messageStore;
 
+    private StoreContext _storeContext = new StoreContext();
+
     private AMQChannel _channel;
 
     private SubscriptionSet _subscriptionManager;
@@ -82,7 +85,7 @@ public class AckTest extends TestCase
 
     private void publishMessages(int count, boolean persistent) throws AMQException
     {
-        TransactionalContext txnContext = new NonTransactionalContext(_messageStore, null,
+        TransactionalContext txnContext = new NonTransactionalContext(_messageStore, _storeContext, null,
                                                                       new LinkedList<RequiredDeliveryException>(),
                                                                       new HashSet<Long>());
         MessageHandleFactory factory = new MessageHandleFactory();
@@ -111,7 +114,7 @@ public class AckTest extends TestCase
             // the reference is normally incremented. The test is easier to construct if we have direct access to the
             // subscription
             msg.incrementReference();
-            msg.routingComplete(_messageStore, factory);
+            msg.routingComplete(_messageStore, _storeContext, factory);
             // we manually send the message to the subscription
             _subscription.send(msg, _queue);
         }