You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2016/11/30 13:27:30 UTC
[10/27] activemq-artemis git commit: Fix createSharedQueue Impl
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 <mt...@redhat.com>
Authored: Tue Nov 29 14:11:27 2016 +0000
Committer: Martyn Taylor <mt...@redhat.com>
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);