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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
