svn commit: r704925 - /incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java

[aidan]

Author: aidan
Date: Wed Oct 15 07:15:58 2008
New Revision: 704925

URL: http://svn.apache.org/viewvc?rev=704925&view=rev
Log:
QPID-1356: Write message to disk before delivering it to queues.

Modified:
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java?rev=704925&r1=704924&r2=704925&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java
 Wed Oct 15 07:15:58 2008
@@ -181,6 +181,10 @@
                 throw new UnauthorizedAccessException("Acccess 
Refused",message);
             }
             
+            // we then allow the transactional context to do something with 
the message content
+            // now that it has all been received, before we attempt delivery
+            _txnContext.messageFullyReceived(isPersistent());
+            
             if ((_destinationQueues == null) || _destinationQueues.size() == 0)
             {
 
@@ -223,9 +227,6 @@
                 }
             }
 
-            // we then allow the transactional context to do something with 
the message content
-            // now that it has all been received, before we attempt delivery
-            _txnContext.messageFullyReceived(isPersistent());
             message.clearStoreContext();
             return message;
         }