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:34:33 UTC
svn commit: r704928 -
/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java
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)
{