activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbert...@apache.org
Subject [6/8] activemq-artemis git commit: Fix auto-created queue config issue with anonymous producer
Date Thu, 08 Dec 2016 16:18:12 GMT
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 <jbertram@apache.com>
Authored: Wed Dec 7 10:40:10 2016 -0600
Committer: jbertram <jbertram@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);


Mime
View raw message