ARTEMIS-856 Fixing ExclusiveTest Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ddd554f4 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ddd554f4 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ddd554f4
Branch: refs/heads/master Commit: ddd554f43fedbabf490b67ce6c2b85a48a2ac954 Parents: ec742cb Author: Michael André Pearce <[email protected]> Authored: Thu Aug 2 13:53:22 2018 +0100 Committer: Michael André Pearce <[email protected]> Committed: Thu Aug 2 13:53:22 2018 +0100 ---------------------------------------------------------------------- .../activemq/artemis/core/server/impl/ActiveMQServerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ddd554f4/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 f01e0c7..a71a862 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 @@ -1766,7 +1766,7 @@ public class ActiveMQServerImpl implements ActiveMQServer { boolean exclusive, boolean lastValue) throws Exception { AddressSettings as = getAddressSettingsRepository().getMatch(address == null ? name.toString() : address.toString()); - createSharedQueue(address, routingType, name, filterString, user, durable, as.getDefaultMaxConsumers(), as.isDefaultPurgeOnNoConsumers(), as.isDefaultExclusiveQueue(), as.isDefaultLastValueQueue(), as.getDefaultConsumersBeforeDispatch(), as.getDefaultDelayBeforeDispatch()); + createSharedQueue(address, routingType, name, filterString, user, durable, maxConsumers, purgeOnNoConsumers, exclusive, lastValue, as.getDefaultConsumersBeforeDispatch(), as.getDefaultDelayBeforeDispatch()); } @Override
