JAMES-2334 Improve rabbit mq image logging
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/c7d08bb7 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/c7d08bb7 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/c7d08bb7 Branch: refs/heads/master Commit: c7d08bb72e0ca8cc214ae5f66841aedad069f511 Parents: 21eec77 Author: benwa <[email protected]> Authored: Tue May 29 10:13:44 2018 +0700 Committer: Matthieu Baechler <[email protected]> Committed: Thu May 31 09:47:02 2018 +0200 ---------------------------------------------------------------------- .../james/queue/rabbitmq/DockerRabbitMQ.java | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/c7d08bb7/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerRabbitMQ.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerRabbitMQ.java b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerRabbitMQ.java index d890c2b..02f89b2 100644 --- a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerRabbitMQ.java +++ b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerRabbitMQ.java @@ -112,19 +112,28 @@ public class DockerRabbitMQ { } public void join(DockerRabbitMQ rabbitMQ) throws Exception { - container() + stopApp(); + joinCluster(rabbitMQ); + } + + private void stopApp() throws java.io.IOException, InterruptedException { + String stdout = container() .execInContainer("rabbitmqctl", "stop_app") .getStdout(); - container() + LOGGER.debug("stop_app: {}", stdout); + } + + private void joinCluster(DockerRabbitMQ rabbitMQ) throws java.io.IOException, InterruptedException { + String stdout = container() .execInContainer("rabbitmqctl", "join_cluster", rabbitMQ.node()) .getStdout(); + LOGGER.debug("join_cluster: {}", stdout); } public void startApp() throws Exception { String stdout = container() .execInContainer("rabbitmqctl", "start_app") .getStdout(); - System.out.println(stdout); - + LOGGER.debug("start_app: {}", stdout); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
