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

NO-JIRA Fixing intermittent failure on JMSTransactionTest 

We can't block the netty thread (which is used by the Listener) otherwise everything just blocks and nothing works on the client
This commit is contained in:
Clebert Suconic 2022-12-13 13:33:23 -05:00
parent 4924bd6b81
commit ef67ea0e26
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/JMSTransactionTest.java
View File

@ -33,6 +33,7 @@ import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
public class JMSTransactionTest extends JMSTestBase {
@ -70,7 +71,7 @@ public class JMSTransactionTest extends JMSTestBase {
@Override
public void onCompletion(Message message) {
try {
commitLatch.await();
commitLatch.await(100, TimeUnit.MILLISECONDS); // can't block the netty thread. We will delay things, but can't block it otherwise the test just blocks
sentMessages.incrementAndGet();
} catch (Exception e) {
e.printStackTrace();