Fix createSharedQueue Impl
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/fa926e48 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/fa926e48 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/fa926e48 Branch: refs/heads/ARTEMIS-780 Commit: fa926e48854975cf107f39ff07f21d7e2b49a320 Parents: 9e3953b Author: Martyn Taylor <[email protected]> Authored: Tue Nov 29 14:11:27 2016 +0000 Committer: Martyn Taylor <[email protected]> Committed: Tue Nov 29 14:11:27 2016 +0000 ---------------------------------------------------------------------- .../core/server/impl/ActiveMQServerImpl.java | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fa926e48/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java ---------------------------------------------------------------------- diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java index d27fad2..8546fc2 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java @@ -1472,7 +1472,10 @@ public class ActiveMQServerImpl implements ActiveMQServer { } @Override - public void createSharedQueue(final SimpleString address, RoutingType routingType, final SimpleString name, final SimpleString filterString, + public void createSharedQueue(final SimpleString address, + RoutingType routingType, + final SimpleString name, + final SimpleString filterString, final SimpleString user, boolean durable) throws Exception { //force the old contract about address @@ -1488,7 +1491,19 @@ public class ActiveMQServerImpl implements ActiveMQServer { } } - final Queue queue = createQueue(address, routingType, name, filterString, user, durable, !durable, false); + final Queue queue = createQueue(address, + name, + routingType, + filterString, + user, + durable, + !durable, + true, + !durable, + false, + Queue.MAX_CONSUMERS_UNLIMITED, + false, + true); if (!queue.getAddress().equals(address)) { throw ActiveMQMessageBundle.BUNDLE.queueSubscriptionBelongsToDifferentAddress(name);
