diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java index 6b498d4d98..6287172ce8 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java @@ -137,7 +137,7 @@ public class IncomingMessage implements Filterable<RuntimeException> { for (int i = 0; i < _destinationQueues.size(); i++) { - _messageStore.enqueueMessage(_txnContext.getStoreContext(), + store.enqueueMessage(_txnContext.getStoreContext(), _destinationQueues.get(i), _messageId); } } |