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 | 617d82c7863006a9d789a9a3cb80eabc9eddd92c (patch) | |
| tree | d8be95d941f4148b3ff398390183854001ff4e57 /qpid/java | |
| parent | e4d2edff2baba92da1fa146aca2ed129721efa0a (diff) | |
| download | qpid-python-617d82c7863006a9d789a9a3cb80eabc9eddd92c.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@945536 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java index e2f6b5cfce..7d0163510a 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java +++ b/qpid/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())) |