summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/src
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2008-08-07 11:15:01 +0000
committerAidan Skinner <aidan@apache.org>2008-08-07 11:15:01 +0000
commit011ba4a3e4990077c468f122a9575018a9f09965 (patch)
treebe24a7dd8f4561aeaf7edff2ff96a589254140d9 /qpid/java/broker-plugins/src
parent1a73ea214ea2dd7e0542f97d8bf9df88855f9084 (diff)
downloadqpid-python-011ba4a3e4990077c468f122a9575018a9f09965.tar.gz
QPID-1218: Boost broker performance by lots.
AMQMessage: Allow references to be incremented in a pile IncomingMessage: Increment message references in one go, flatten delivery loop a little. Make _destinationQueues an ArrayList, massively increasing performance. Iter ate through it with indexing AccessResult: don't use StringBuilder so much Update tests and exchanges to reflect new API usage, almost all of this is just type narrowing except for Topic where there's an extra copy, but it isn't too bad relative to the number of HashSet and HashMap operations that go on inside there. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@683583 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/src')
-rw-r--r--qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java b/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
index 0b7e300cec..027d220538 100644
--- a/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
+++ b/qpid/java/broker-plugins/src/main/java/org/apache/qpid/extras/exchanges/diagnostic/DiagnosticExchange.java
@@ -204,7 +204,7 @@ public class DiagnosticExchange extends AbstractExchange
((BasicContentHeaderProperties)payload.getContentHeaderBody().properties).setHeaders(headers);
AMQQueue q = getQueueRegistry().getQueue(new AMQShortString("diagnosticqueue"));
- Collection<AMQQueue> queues = new ArrayList<AMQQueue>();
+ ArrayList<AMQQueue> queues = new ArrayList<AMQQueue>();
queues.add(q);
payload.enqueue(queues);