summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src
diff options
context:
space:
mode:
authorBhupendra Bhusman Bhardwaj <bhupendrab@apache.org>2007-02-01 10:13:55 +0000
committerBhupendra Bhusman Bhardwaj <bhupendrab@apache.org>2007-02-01 10:13:55 +0000
commitb12db1a36b5d01992b794534cf016189d35efc19 (patch)
treeebebd4e017fc9a0687bdb7545c747d9772d6ae29 /qpid/java/broker/src
parent2433bfc0e042cb76578fde6f54b4f88cc208c02c (diff)
downloadqpid-python-b12db1a36b5d01992b794534cf016189d35efc19.tar.gz
QPID-331
and setting operation parameters to default values after executing the operation once. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@502180 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src')
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/AMQBrokerManagerMBean.java7
1 files changed, 6 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQBrokerManagerMBean.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQBrokerManagerMBean.java
index 204b5674ce..0b8aac67b6 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQBrokerManagerMBean.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/AMQBrokerManagerMBean.java
@@ -153,7 +153,12 @@ public class AMQBrokerManagerMBean extends AMQManagedObject implements ManagedBr
try
{
- queue = new AMQQueue(new AMQShortString(queueName), durable, new AMQShortString(owner), autoDelete, getVirtualHost());
+ AMQShortString ownerShortString = null;
+ if (owner != null)
+ {
+ ownerShortString = new AMQShortString(owner);
+ }
+ queue = new AMQQueue(new AMQShortString(queueName), durable, ownerShortString, autoDelete, getVirtualHost());
if (queue.isDurable() && !queue.isAutoDelete())
{
_messageStore.createQueue(queue);