[james-project] 24/27: JAMES-3225 log amqp docker image output to debug level

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

matthieu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit b65f1fc08d259cee5c7a393555c15b553b8bcfe4
Author: Jean Helou <jh...@codamens.fr>
AuthorDate: Fri Feb 5 09:14:24 2021 +0100

    JAMES-3225 log amqp docker image output to debug level
    
    this will allow it to be picked up by test-run.log for CI failure diags
---
 .../apache/james/transport/mailets/amqp/AmqpExtension.java    | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/server/mailet/integration-testing/src/test/java/org/apache/james/transport/mailets/amqp/AmqpExtension.java b/server/mailet/integration-testing/src/test/java/org/apache/james/transport/mailets/amqp/AmqpExtension.java
index 6a37166..f4ac1e2 100644
--- a/server/mailet/integration-testing/src/test/java/org/apache/james/transport/mailets/amqp/AmqpExtension.java
+++ b/server/mailet/integration-testing/src/test/java/org/apache/james/transport/mailets/amqp/AmqpExtension.java
@@ -35,6 +35,9 @@ import org.junit.jupiter.api.extension.BeforeAllCallback;
 import org.junit.jupiter.api.extension.BeforeEachCallback;
 import org.junit.jupiter.api.extension.ExtensionContext;
 import org.junit.rules.ExternalResource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.testcontainers.containers.output.OutputFrame;
 import org.testcontainers.containers.wait.strategy.HostPortWaitStrategy;
 
 import com.rabbitmq.client.BuiltinExchangeType;
@@ -45,6 +48,7 @@ import com.rabbitmq.client.GetResponse;
 
 public class AmqpExtension implements BeforeAllCallback, AfterAllCallback, AfterEachCallback {
     private static final boolean AUTO_ACK = true;
+    private static final Logger logger = LoggerFactory.getLogger(AmqpExtension.class);
 
     private final DockerContainer rabbitMqContainer;
     private final String exchangeName;
@@ -58,11 +62,16 @@ public class AmqpExtension implements BeforeAllCallback, AfterAllCallback, After
         this.rabbitMqContainer = DockerContainer.fromName(Images.RABBITMQ)
             .withAffinityToContainer()
             .waitingFor(new HostPortWaitStrategy()
-                .withRateLimiter(RateLimiters.TWENTIES_PER_SECOND));;
+                .withRateLimiter(RateLimiters.TWENTIES_PER_SECOND))
+                .withLogConsumer(AmqpExtension::displayDockerLog);
         this.exchangeName = exchangeName;
         this.routingKey = routingKey;
     }
 
+    private static void displayDockerLog(OutputFrame outputFrame) {
+        logger.debug(outputFrame.getUtf8String().trim());
+    }
+
     @Override
     public void beforeAll(ExtensionContext extensionContext) throws Exception {
         rabbitMqContainer.start();


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org