Fix intermittent failure of messaging tests

Fixes apache#1023
jamesnetherton · Apr 3, 2020 · 7ce4646 · 7ce4646
1 parent 935b6db
commit 7ce4646
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/...g/src/test/java/org/apache/camel/quarkus/component/messaging/it/ActiveMQTestResource.java b/...g/src/test/java/org/apache/camel/quarkus/component/messaging/it/ActiveMQTestResource.java
@@ -17,12 +17,14 @@
 package org.apache.camel.quarkus.component.messaging.it;
 
 import java.util.Map;
+import java.util.function.Consumer;
 
 import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
 import org.apache.camel.util.CollectionHelper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.output.OutputFrame;
 import org.testcontainers.containers.wait.strategy.Wait;
 import org.testcontainers.utility.TestcontainersConfiguration;
 
@@ -43,6 +45,13 @@ public Map<String, String> start() {
         try {
             container = new GenericContainer(ACTIVEMQ_IMAGE)
                     .withExposedPorts(ACTIVEMQ_PORT)
+                    .withLogConsumer(new Consumer<OutputFrame>() {
+                        @Override
+                        public void accept(OutputFrame outputFrame) {
+                            System.out.println(outputFrame.getUtf8String());
+                        }
+                    })
+                    .withEnv("BROKER_CONFIG_MAX_DISK_USAGE", "100")
                     .waitingFor(Wait.forListeningPort());
 
             container.start();

diff --git a/...ests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java b/...ests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java
@@ -20,15 +20,13 @@
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.RestAssured;
 import io.restassured.http.ContentType;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
 import static org.hamcrest.core.Is.is;
 
 @QuarkusTest
 @QuarkusTestResource(ActiveMQTestResource.class)
-@Disabled("https://github.com/apache/camel-quarkus/issues/1023")
 class JmsTest {
 
     @ParameterizedTest