You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2021/10/11 00:56:38 UTC
[activemq-artemis] branch main updated: ARTEMIS-3313 fixing
intermittent test failure
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 377cda6 ARTEMIS-3313 fixing intermittent test failure
377cda6 is described below
commit 377cda62b2f737a3e7fa05936efb1976a1de7142
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Sun Oct 10 20:50:27 2021 -0400
ARTEMIS-3313 fixing intermittent test failure
---
.../artemis/tests/integration/persistence/XmlImportExportTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/persistence/XmlImportExportTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/persistence/XmlImportExportTest.java
index d53a853..72f1576 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/persistence/XmlImportExportTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/persistence/XmlImportExportTest.java
@@ -57,6 +57,7 @@ import org.apache.activemq.artemis.jms.server.impl.JMSServerManagerImpl;
import org.apache.activemq.artemis.tests.unit.util.InVMContext;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.activemq.artemis.tests.util.RandomUtil;
+import org.apache.activemq.artemis.tests.util.Wait;
import org.apache.activemq.artemis.utils.UUIDGenerator;
import org.jboss.logging.Logger;
import org.junit.Test;
@@ -1152,7 +1153,7 @@ public class XmlImportExportTest extends ActiveMQTestBase {
producer.send(createTextMessage(session, payload).putByteProperty(Message.HDR_ROUTING_TYPE, (byte) 1));
session.start();
ClientConsumer consumer = session.createConsumer(myQueue);
- ClientMessage m = consumer.receive(500);
+ ClientMessage m = consumer.receive(5000);
m.acknowledge();
assertNotNull(m);
@@ -1189,10 +1190,10 @@ public class XmlImportExportTest extends ActiveMQTestBase {
xmlDataImporter.process(xmlInputStream, session, managementSession);
//Check that message is imported with no "routingType" and is intact
- assertTrue(server.getTotalMessageCount() == 1);
+ Wait.assertTrue(() -> server.getTotalMessageCount() == 1);
session.start();
consumer = session.createConsumer(dlaPrefix.concat(myAddress));
- m = consumer.receive(500);
+ m = consumer.receive(5000);
assertNotNull(m);
assertEquals(m.getBodyBuffer().readString(), payload);