Add debug logging in test

Author: acogoluegnes

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

@@ -82,10 +82,14 @@
 import org.junit.jupiter.params.provider.CsvSource;
 import org.junit.jupiter.params.provider.EnumSource;
 import org.junit.jupiter.params.provider.ValueSource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 @AmqpTestInfrastructure
 public class AmqpTest {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(AmqpTest.class);
+
   Connection connection;
   Environment environment;
   String name;
@@ -1636,6 +1640,12 @@ void asyncMessageAcceptanceWithExecutorService() {
 
     AtomicReference<ExecutorService> executorService = new AtomicReference<>();
 
+    Sync consumeSync = sync(messageCount);
+    AtomicInteger received = new AtomicInteger();
+    AtomicInteger dispatched = new AtomicInteger();
+    AtomicInteger executed = new AtomicInteger();
+    AtomicInteger processed = new AtomicInteger();
+    AtomicInteger accepted = new AtomicInteger();
     try {
       Sync publishSync = sync(messageCount);
       range(0, messageCount)
@@ -1646,31 +1656,35 @@ void asyncMessageAcceptanceWithExecutorService() {
 
       assertThat(publishSync).completes();
       publisher.close();
+      LOGGER.debug("Published {} messages in queue '{}'", messageCount, name);
 
       executorService.set(Executors.newFixedThreadPool(executorThreads));
-      Sync consumeSync = sync(messageCount);
       long[] simulatedLatencies = new long[executorThreads];
       Random random = new Random();
       for (int i = 0; i < executorThreads; i++) {
         simulatedLatencies[i] = random.nextInt(4) + 1;
       }
       AtomicInteger count = new AtomicInteger();
       Supplier<Long> latency = () -> simulatedLatencies[count.getAndIncrement() % executorThreads];
-
       consumer =
           connection
               .consumerBuilder()
               .queue(name)
               .messageHandler(
                   (context, message) -> {
+                    received.incrementAndGet();
                     executorService
                         .get()
                         .submit(
                             () -> {
+                              executed.incrementAndGet();
                               TestUtils.simulateActivity(latency.get());
+                              processed.incrementAndGet();
                               context.accept();
+                              accepted.incrementAndGet();
                               consumeSync.down();
                             });
+                    dispatched.incrementAndGet();
                   })
               .build();
 
@@ -1679,6 +1693,19 @@ void asyncMessageAcceptanceWithExecutorService() {
       Management.QueueInfo queueInfo = connection.management().queueInfo(name);
       assertThat(queueInfo).hasName(name).hasMessageCount(0);
     } finally {
+      if (consumer != null) {
+        LOGGER.debug("Consumer state: '{}'", ((AmqpConsumer) consumer).diagnosticState());
+      }
+      LOGGER.debug(
+          "Counters: received={}, dispatched={}, executed={}, processed={}, accepted={}",
+          received.get(),
+          dispatched.get(),
+          executed.get(),
+          processed.get(),
+          accepted.get());
+      LOGGER.debug("Consume latch: {}", consumeSync.count());
+      LOGGER.debug("Queue info: {}", connection.management().queueInfo(name));
+
       if (consumer != null) {
         consumer.close();
       }

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

@@ -680,6 +680,10 @@ boolean hasCompleted() {
       return this.latch.get().getCount() == 0;
     }
 
+    long count() {
+      return this.latch.get().getCount();
+    }
+
     @Override
     public String toString() {
       return this.description;

src/test/resources/log4j2-test.xml

@@ -12,6 +12,7 @@
 
   <Loggers>
     <Logger name="com.rabbitmq.client.amqp.AmqpClientTestExtension" level="warn" />
+    <Logger name="com.rabbitmq.client.amqp.impl.AmqpTest" level="debug" />
     <Logger name="com.rabbitmq.client.amqp" level="warn" />
     <Logger name="org.apache.qpid" level="error" />
     <Logger name="com.rabbitmq.client.amqp.perf" level="info" />