From 1727e9afd4de91736cb1012126f6b8d9e1fa1ab0 Mon Sep 17 00:00:00 2001 From: Aidan Skinner Date: Fri, 17 Apr 2009 13:47:08 +0000 Subject: QPID-1820: configure queues on creation git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@766004 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/server/queue/AMQQueueFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'qpid/java') 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; } -- cgit v1.2.1