This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/master by this push:
new eb4cd20 ARTEMIS-2692 Fixing tests on queue creation
eb4cd20 is described below
commit eb4cd209b1d774db8295758f4fe42b1fd00d5997
Author: Clebert Suconic <[email protected]>
AuthorDate: Mon Apr 13 20:58:14 2020 -0400
ARTEMIS-2692 Fixing tests on queue creation
Fixing mishap / typo
---
.../java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
index 9fe7480..28d1c5b 100644
---
a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
+++
b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
@@ -1262,13 +1262,13 @@ public class ActiveMQSession implements QueueSession,
TopicSession {
void createSharedQueue(ActiveMQDestination destination, RoutingType
routingType, SimpleString queueName, SimpleString filter, boolean durable,
ClientSession.AddressQuery addressQuery) throws ActiveMQException {
QueueConfiguration queueConfiguration =
destination.getQueueConfiguration() == null ? new QueueConfiguration(queueName)
: destination.getQueueConfiguration();
setRequiredQueueConfigurationIfNotSet(queueConfiguration, addressQuery,
routingType, filter, durable);
-
session.createSharedQueue(queueConfiguration.setName(queueName).setAddress(destination.getAddress()));
+
session.createSharedQueue(queueConfiguration.setName(queueName).setAddress(destination.getAddress()).setDurable(durable));
}
void createQueue(ActiveMQDestination destination, RoutingType routingType,
SimpleString queueName, SimpleString filter, boolean durable, boolean
autoCreated, ClientSession.AddressQuery addressQuery) throws ActiveMQException {
QueueConfiguration queueConfiguration =
destination.getQueueConfiguration() == null ? new QueueConfiguration(queueName)
: destination.getQueueConfiguration();
setRequiredQueueConfigurationIfNotSet(queueConfiguration, addressQuery,
routingType, filter, durable);
-
session.createQueue(queueConfiguration.setName(queueName).setAddress(destination.getAddress()).setAutoCreated(autoCreated));
+
session.createQueue(queueConfiguration.setName(queueName).setAddress(destination.getAddress()).setAutoCreated(autoCreated).setDurable(durable));
}
// Private -------------------------------------------------------
