summaryrefslogtreecommitdiff
path: root/java/broker
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2009-04-17 13:46:59 +0000
committerAidan Skinner <aidan@apache.org>2009-04-17 13:46:59 +0000
commit9dc2c65db6447faf152b9c0798428c2288126fe8 (patch)
treee831c38b28f61d1e1c7e57a96ffc796fc785bdb9 /java/broker
parent78e08815915b567e127babcb2210ba4fa3640df1 (diff)
downloadqpid-python-9dc2c65db6447faf152b9c0798428c2288126fe8.tar.gz
QPID-1820: configure queues on creation
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@766004 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java
index 84b59456cb..7509350e65 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java
+++ b/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;
}