diff options
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java')
-rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java index dfbbd56d6f..0b48feddcd 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/ack/TxAckTest.java @@ -38,7 +38,6 @@ import org.apache.qpid.server.queue.AMQQueueFactory; import org.apache.qpid.server.queue.AMQQueue; import org.apache.qpid.server.store.TestMemoryMessageStore; import org.apache.qpid.server.store.StoreContext; -import org.apache.qpid.server.store.MemoryMessageStore; import org.apache.qpid.server.txn.NonTransactionalContext; import org.apache.qpid.server.txn.TransactionalContext; @@ -163,7 +162,9 @@ public class TxAckTest extends TestCase }; TestMessage message = new TestMessage(deliveryTag, i, info, txnContext.getStoreContext()); - _map.add(deliveryTag, _queue.enqueue(new StoreContext(), message)); + StoreContext sc = StoreContext.setCurrentContext(new StoreContext()); + _map.add(deliveryTag, _queue.enqueue(message)); + StoreContext.setCurrentContext(sc); } _acked = acked; _unacked = unacked; |