diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java index 1b335cf964..ed9d58994a 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java @@ -439,7 +439,7 @@ public class SendingLink_1_0 implements SendingLinkListener, Link_1_0, DeliveryS if(outcome instanceof Accepted) { - AutoCommitTransaction txn = new AutoCommitTransaction(_vhost.getTransactionLog()); + AutoCommitTransaction txn = new AutoCommitTransaction(_vhost.getMessageStore()); if(_subscription.acquires()) { txn.dequeue(Collections.singleton(queueEntry), @@ -459,7 +459,7 @@ public class SendingLink_1_0 implements SendingLinkListener, Link_1_0, DeliveryS } else if(outcome instanceof Released) { - AutoCommitTransaction txn = new AutoCommitTransaction(_vhost.getTransactionLog()); + AutoCommitTransaction txn = new AutoCommitTransaction(_vhost.getMessageStore()); if(_subscription.acquires()) { txn.dequeue(Collections.singleton(queueEntry), |