From 617d82c7863006a9d789a9a3cb80eabc9eddd92c Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Tue, 18 May 2010 08:22:09 +0000 Subject: 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 --- qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'qpid/java') 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 destinationQueues = _currentMessage.getDestinationQueues(); if(!checkMessageUserId(_currentMessage.getContentHeader())) -- cgit v1.2.1