Add logs in test

Author: acogoluegnes

src/test/java/com/rabbitmq/client/amqp/impl/ClusterTest.java

@@ -46,6 +46,7 @@
 import com.rabbitmq.client.amqp.Resource;
 import com.rabbitmq.client.amqp.impl.TestUtils.DisabledIfNotCluster;
 import com.rabbitmq.client.amqp.impl.TestUtils.Sync;
+import java.time.Duration;
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
@@ -59,10 +60,14 @@
 import org.junit.jupiter.api.TestInfo;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.EnumSource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 @DisabledIfNotCluster
 public class ClusterTest {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(ClusterTest.class);
+
   static final String[] URIS =
       new String[] {"amqp://localhost:5672", "amqp://localhost:5673", "amqp://localhost:5674"};
   static final BackOffDelayPolicy BACK_OFF_DELAY_POLICY = BackOffDelayPolicy.fixed(ofMillis(100));
@@ -339,9 +344,13 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() throws InterruptedException {
 
       assertThat(initialFollowers).isNotEmpty();
 
+      LOGGER.info("Pausing node {}", initialLeader);
+
       Cli.pauseNode(initialLeader);
       nodePaused = true;
 
+      LOGGER.info("Node {} paused", initialLeader);
+
       publisher.publish(publisher.message().messageId(2L), ctx -> publishSync.down());
 
       assertThat(publishSync).completes(ofSeconds(20));
@@ -351,6 +360,9 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() throws InterruptedException {
       assertThat(messageIds).containsExactlyInAnyOrder(1L, 2L);
       consumeSync.reset();
 
+      LOGGER.info("Waiting for topology update");
+      long start = System.nanoTime();
+
       waitAtMost(
           ofSeconds(60),
           () -> initialFollowers.contains(mgmt.queueInfo(q).leader()),
@@ -361,8 +373,14 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() throws InterruptedException {
                   + "queue info "
                   + mgmt.queueInfo(q));
 
+      LOGGER.info(
+          "Topology updated after {} second(s)",
+          Duration.ofNanos(System.nanoTime() - start).toSeconds());
+
+      LOGGER.info("Unpausing node {}", initialLeader);
       Cli.unpauseNode(initialLeader);
       nodePaused = false;
+      LOGGER.info("Node {} unpaused", initialLeader);
 
       publisher.publish(publisher.message().messageId(3L), ctx -> publishSync.down());
       assertThat(publishSync).completes();

src/test/resources/logback-test.xml

@@ -10,6 +10,7 @@
     <logger name="com.rabbitmq.client.amqp" level="warn" />
     <logger name="org.apache.qpid" level="error" />
     <logger name="com.rabbitmq.client.amqp.perf" level="info" />
+    <logger name="com.rabbitmq.client.amqp.impl.ClusterTest" level="info" />
 <!--    <logger name="com.rabbitmq.client.amqp.impl.ConnectionUtils" level="debug" />-->
 <!--    <logger name="com.rabbitmq.client.amqp.impl.AmqpConnection" level="debug" />-->
 <!--    <logger name="com.rabbitmq.client.amqp.impl.RecoveryClusterTest" level="info" />-->