summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2009-04-17 13:47:08 +0000
committerAidan Skinner <aidan@apache.org>2009-04-17 13:47:08 +0000
commit1727e9afd4de91736cb1012126f6b8d9e1fa1ab0 (patch)
treeb534ce9f40506c7a6b1ef9047698d4b59aa79028 /qpid/java
parent9359cf7975bdc6afe7f8b2b48f61452a21db950b (diff)
downloadqpid-python-1727e9afd4de91736cb1012126f6b8d9e1fa1ab0.tar.gz
QPID-1820: configure queues on creation
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@766004 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java
index 84b59456cb..7509350e65 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java
@@ -38,7 +38,6 @@ public class AMQQueueFactory
VirtualHost virtualHost, final FieldTable arguments)
throws AMQException
{
-
final int priorities = arguments == null ? 1 : arguments.containsKey(X_QPID_PRIORITIES) ? arguments.getInteger(X_QPID_PRIORITIES) : 1;
AMQQueue q = null;
@@ -53,6 +52,7 @@ public class AMQQueueFactory
//Register the new queue
virtualHost.getQueueRegistry().registerQueue(q);
+ q.configure(virtualHost.getConfiguration().getQueueConfiguration(name.asString()));
return q;
}