Author: aidan
Date: Wed Oct 15 07:34:32 2008
New Revision: 704928
URL: http://svn.apache.org/viewvc?rev=704928&view=rev
Log:
QPID-1356: move commit even higher, before the auth check.
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=704928&r1=704927&r2=704928&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:34:32 2008
@@ -173,6 +173,10 @@
message.setExpiration(_expiration);
message.setClientIdentifier(_publisher.getSessionIdentifier());
+ // 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());
+
AMQShortString userID = getContentHeaderBody().properties
instanceof BasicContentHeaderProperties ?
((BasicContentHeaderProperties)
getContentHeaderBody().properties).getUserId() : null;
@@ -181,10 +185,6 @@
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)
{
