From 6879a1149f0733b67d2073a7b0ccfed7f517d994 Mon Sep 17 00:00:00 2001 From: Aidan Skinner Date: Wed, 15 Oct 2008 14:34:32 +0000 Subject: QPID-1356: move commit even higher, before the auth check. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@704928 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/server/queue/IncomingMessage.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'java') diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java b/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java index 896747fc83..b994040131 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java +++ b/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java @@ -173,6 +173,10 @@ public class IncomingMessage implements Filterable 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 @@ public class IncomingMessage implements Filterable 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) { -- cgit v1.2.1