You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2016/12/08 16:18:12 UTC
[6/8] activemq-artemis git commit: Fix auto-created queue config
issue with anonymous producer
Fix auto-created queue config issue with anonymous producer
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ae849f5d
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ae849f5d
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ae849f5d
Branch: refs/heads/ARTEMIS-780
Commit: ae849f5d9a4745e5f9713ffd34448d545641b678
Parents: 10fb7f6
Author: jbertram <jb...@apache.com>
Authored: Wed Dec 7 10:40:10 2016 -0600
Committer: jbertram <jb...@apache.com>
Committed: Thu Dec 8 08:43:43 2016 -0600
----------------------------------------------------------------------
.../activemq/artemis/jms/client/ActiveMQMessageProducer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ae849f5d/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
----------------------------------------------------------------------
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
index ecc47bc..e8d1171 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
@@ -412,7 +412,7 @@ public class ActiveMQMessageProducer implements MessageProducer, QueueSender, To
// TODO is it right to use the address for the queue name here?
clientSession.createTemporaryQueue(address, RoutingType.ANYCAST, address);
} else {
- clientSession.createQueue(address, RoutingType.ANYCAST, address, null, true, true);
+ clientSession.createQueue(address, RoutingType.ANYCAST, address, null, true, true, query.getDefaultMaxConsumers(), query.isDefaultDeleteOnNoConsumers());
}
} else if (!destination.isQueue() && query.isAutoCreateAddresses()) {
clientSession.createAddress(address, RoutingType.MULTICAST, true);