This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 579818d0182bbf6a1daa95c047e7ceddd2c7d1cb Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Thu May 30 10:50:19 2024 +0200 (chores) camel-test-infra-rocketmq: adjustments to help with flakiness - add more logging to help with flakiness - invert shutdown order --- .../test/infra/rocketmq/services/RocketMQContainerService.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainerService.java b/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainerService.java index b8e2af195ec..721e087e153 100644 --- a/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainerService.java +++ b/test-infra/camel-test-infra-rocketmq/src/test/java/org/apache/camel/test/infra/rocketmq/services/RocketMQContainerService.java @@ -60,16 +60,18 @@ public class RocketMQContainerService implements RocketMQService, ContainerServi @Override public void initialize() { + LOG.info("Starting nameserver"); nameserverContainer.start(); - LOG.info("Apache RocketMQ running at address {}", nameserverAddress()); + LOG.info("Starting broker"); brokerContainer1.start(); + LOG.info("Apache RocketMQ running at address {}", nameserverAddress()); } @Override public void shutdown() { - nameserverContainer.stop(); brokerContainer1.stop(); + nameserverContainer.stop(); } public void createTopic(String topic) {
