From eb4cd209b1d774db8295758f4fe42b1fd00d5997 Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Mon, 13 Apr 2020 20:58:14 -0400 Subject: [PATCH] ARTEMIS-2692 Fixing tests on queue creation Fixing mishap / typo --- .../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 9fe7480fc2..28d1c5bd09 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 -------------------------------------------------------