[activemq] branch master updated: fix intermittent failure, two brokers in the mix

[gtully]

This is an automated email from the ASF dual-hosted git repository.

gtully pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/master by this push:
     new b9851a8  fix intermittent failure, two brokers in the mix
b9851a8 is described below

commit b9851a8fc29369f77a7120668681692ed73e229e
Author: gtully <gary.tu...@gmail.com>
AuthorDate: Mon Dec 2 15:14:42 2019 +0000

    fix intermittent failure, two brokers in the mix
---
 .../src/test/java/org/apache/activemq/ra/MDBTest.java      | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/activemq-ra/src/test/java/org/apache/activemq/ra/MDBTest.java 
b/activemq-ra/src/test/java/org/apache/activemq/ra/MDBTest.java
index 93b631c..7a44345 100644
--- a/activemq-ra/src/test/java/org/apache/activemq/ra/MDBTest.java
+++ b/activemq-ra/src/test/java/org/apache/activemq/ra/MDBTest.java
@@ -186,7 +186,7 @@ public class MDBTest {
         MessageConsumer advisory = 
session.createConsumer(AdvisorySupport.getConsumerAdvisoryTopic(new 
ActiveMQQueue("TEST")));
 
         ActiveMQResourceAdapter adapter = new ActiveMQResourceAdapter();
-        adapter.setServerUrl("vm://localhost?broker.persistent=false");
+        
adapter.setServerUrl("vm://localhost?broker.persistent=false&create=false");
         adapter.setQueuePrefetch(1);
         adapter.start(new StubBootstrapContext());
 
@@ -255,7 +255,7 @@ public class MDBTest {
         MessageConsumer advisory = 
session.createConsumer(AdvisorySupport.getConsumerAdvisoryTopic(new 
ActiveMQQueue("TEST")));
 
         ActiveMQResourceAdapter adapter = new ActiveMQResourceAdapter();
-        adapter.setServerUrl("vm://localhost?broker.persistent=false");
+        
adapter.setServerUrl("vm://localhost?broker.persistent=false&create=false");
         adapter.setQueuePrefetch(1);
         adapter.start(new StubBootstrapContext());
 
@@ -320,7 +320,7 @@ public class MDBTest {
         connection.start();
         Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
         ActiveMQResourceAdapter adapter = new ActiveMQResourceAdapter();
-        adapter.setServerUrl("vm://localhost?broker.persistent=false");
+        
adapter.setServerUrl("vm://localhost?broker.persistent=false&create=false");
         adapter.start(new StubBootstrapContext());
 
         final CountDownLatch messageDelivered = new CountDownLatch(10);
@@ -618,7 +618,7 @@ public class MDBTest {
         Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
 
         ActiveMQResourceAdapter adapter = new ActiveMQResourceAdapter();
-        adapter.setServerUrl("vm://localhost?broker.persistent=false");
+        
adapter.setServerUrl("vm://localhost?broker.persistent=false?create=false");
         adapter.start(new StubBootstrapContext());
 
         final CountDownLatch messageDelivered = new CountDownLatch(5);
@@ -720,7 +720,7 @@ public class MDBTest {
         Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
 
         ActiveMQResourceAdapter adapter = new ActiveMQResourceAdapter();
-        adapter.setServerUrl("vm://localhost?broker.persistent=false");
+        
adapter.setServerUrl("vm://localhost?broker.persistent=false&create=false");
         adapter.start(new StubBootstrapContext());
         final String ORDER_PROP = "Order";
         final List<Integer> orderedReceipt = new ArrayList<Integer>();
@@ -823,7 +823,7 @@ public class MDBTest {
         Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
 
         ActiveMQResourceAdapter adapter = new ActiveMQResourceAdapter();
-        adapter.setServerUrl("vm://localhost?broker.persistent=false");
+        
adapter.setServerUrl("vm://localhost?broker.persistent=false&create=false");
         adapter.start(new StubBootstrapContext());
 
         final CountDownLatch messageDelivered = new CountDownLatch(2);
@@ -915,7 +915,7 @@ public class MDBTest {
         Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
 
         ActiveMQResourceAdapter adapter = new ActiveMQResourceAdapter();
-        adapter.setServerUrl("vm://localhost?broker.persistent=false");
+        
adapter.setServerUrl("vm://localhost?broker.persistent=false&create=false");
         adapter.start(new StubBootstrapContext());
 
         final CountDownLatch messageDelivered = new CountDownLatch(1);