Update Queue implementation to better define lifetime and exclusivity policiesjava-broker-amqp-1-0-management

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-amqp-1-0-management@1569102 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 2 deletions

diff --git a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/VirtualHostManagerMBean.java b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/VirtualHostManagerMBean.java
index 2c88f83405..c39c3f74e9 100644
--- a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/VirtualHostManagerMBean.java
+++ b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/VirtualHostManagerMBean.java
@@ -181,8 +181,13 @@ public class VirtualHostManagerMBean extends AbstractStatisticsGatheringMBean<Vi
             throws IOException, JMException
     {
         final Map<String, Object> createArgs = processNewQueueArguments(queueName, owner, originalArguments);
-        getConfiguredObject().createQueue(queueName, State.ACTIVE, durable, false, LifetimePolicy.PERMANENT, 0l,
-                QueueArgumentsConverter.convertWireArgsToModel(createArgs));
+
+        final Map<String, Object> attributes = QueueArgumentsConverter.convertWireArgsToModel(createArgs);
+        attributes.put(Queue.NAME, queueName);
+        attributes.put(Queue.DURABLE, durable);
+        attributes.put(Queue.LIFETIME_POLICY, LifetimePolicy.PERMANENT);
+
+        getConfiguredObject().createQueue(attributes);
     }