diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java index 896747fc83..b994040131 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/IncomingMessage.java @@ -173,6 +173,10 @@ public class IncomingMessage implements Filterable<RuntimeException> 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<RuntimeException> 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) { |