You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2019/09/25 13:08:30 UTC
[activemq] branch master updated: no jira - fix intermittent test
failure
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 1c5beda no jira - fix intermittent test failure
1c5beda is described below
commit 1c5beda8347a26ef7b666f8842e99a2b54c55cac
Author: gtully <ga...@gmail.com>
AuthorDate: Wed Sep 25 14:08:17 2019 +0100
no jira - fix intermittent test failure
---
.../apache/activemq/transport/failover/FailoverTransactionTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
index a7f8cbb..27ed767 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
@@ -667,7 +667,7 @@ public class FailoverTransactionTest extends TestSupport {
connection.start();
Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
- Queue destination = session.createQueue(QUEUE_NAME);
+ Queue destination = session.createQueue("testFailoverWithConnectionConsumer");
final CountDownLatch connectionConsumerGotOne = new CountDownLatch(1);
final Session poolSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
@@ -903,6 +903,7 @@ public class FailoverTransactionTest extends TestSupport {
configureConnectionFactory(cf);
Connection connection = cf.createConnection();
connection.start();
+ connections.add(connection);
Session producerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
final Queue destination = producerSession.createQueue(QUEUE_NAME + "?consumer.prefetchSize=1");