You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ai...@apache.org on 2008/10/15 16:15:58 UTC
svn commit: r704925 -
/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java
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;
}