Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix intermittent failure, two brokers in the mix

This commit is contained in:
gtully 2019-12-02 15:14:42 +00:00
parent 4d6409b3b8
commit b9851a8fc2
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
activemq-ra/src/test/java/org/apache/activemq/ra/MDBTest.java
View File

@ -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);