activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [activemq-artemis] branch master updated: ARTEMIS-2692 Fixing tests on queue creation
Date Tue, 14 Apr 2020 00:59:09 GMT
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 <clebertsuconic@apache.org>
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 -------------------------------------------------------


Mime
View raw message