From 63e3fe0d6db9e6fea43d1f879245ff46084a757f Mon Sep 17 00:00:00 2001
From: Robert Gemmell <robbie@apache.org>
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/qpid@945536 13f79535-47bb-0310-9956-ffa450edef68
---
 java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

(limited to 'java')

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()))
-- 
cgit v1.2.1