From 65ff20b32f391e5127e0b514b70ce7541997b859 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Sun, 25 Oct 2009 19:56:47 +0000 Subject: Only create one AMQMessage perincoming message git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-0-10@829634 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/server/AMQChannel.java | 28 ++++++++++++---------- 1 file changed, 16 insertions(+), 12 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java index 35da132833..262bb2f226 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java @@ -48,6 +48,7 @@ import org.apache.qpid.server.txn.*; import org.apache.qpid.server.message.ServerMessage; import org.apache.qpid.server.message.AMQMessage; import org.apache.qpid.server.message.MessageMetaData; +import org.apache.qpid.server.message.MessageReference; import org.apache.qpid.server.registry.ApplicationRegistry; import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.logging.LogSubject; @@ -192,18 +193,18 @@ public class AMQChannel routeCurrentMessage(); - _transaction.addPostCommitAction(new ServerTransaction.Action() - { + _transaction.addPostCommitAction(new ServerTransaction.Action() + { - public void postCommit() - { - } + public void postCommit() + { + } - public void onRollback() - { - handle.remove(); - } - }); + public void onRollback() + { + handle.remove(); + } + }); deliverCurrentMessageIfComplete(); @@ -984,11 +985,13 @@ public class AMQChannel { final boolean immediate = _incommingMessage.isImmediate(); - + final AMQMessage amqMessage = createAMQMessage(_incommingMessage); + MessageReference ref = amqMessage.newReference(); for(AMQQueue queue : _destinationQueues) { - QueueEntry entry = queue.enqueue(createAMQMessage(_incommingMessage)); + + QueueEntry entry = queue.enqueue(amqMessage); queue.checkCapacity(AMQChannel.this); @@ -1035,6 +1038,7 @@ public class AMQChannel } } + ref.release(); } catch (AMQException e) { -- cgit v1.2.1