diff options
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java index b8c5e821f7..7088c704ed 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java +++ b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java @@ -60,7 +60,7 @@ public class UnacknowledgedMessage { if (queue != null) { - message.dequeue(storeContext, queue); + queue.dequeue(storeContext, message); } //if the queue is null then the message is waiting to be acked, but has been removed. message.decrementReference(storeContext); |