diff options
| author | Robert Gemmell <robbie@apache.org> | 2010-05-18 08:22:09 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2010-05-18 08:22:09 +0000 |
| commit | 63e3fe0d6db9e6fea43d1f879245ff46084a757f (patch) | |
| tree | 979dfc975b39029f5883e856a86b5df3eb65c8df | |
| parent | d3cbaf2d9fe228a4e6c2cc15cffa3a3b011b70c7 (diff) | |
| download | qpid-python-63e3fe0d6db9e6fea43d1f879245ff46084a757f.tar.gz | |
QPID-2613: flush 0-8/0-9 message to store when delivery begins
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@945536 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java index e2f6b5cfce..7d0163510a 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java +++ b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java @@ -303,7 +303,8 @@ public class AMQChannel implements SessionConfig, AMQSessionModel { try { - + _currentMessage.getStoredMessage().flushToStore(); + final ArrayList<? extends BaseQueue> destinationQueues = _currentMessage.getDestinationQueues(); if(!checkMessageUserId(_currentMessage.getContentHeader())) |