commit 35e986ce941333872377cdc5a25bc99caa3aba04
author Benoit TELLIER <btellier@linagora.com> Fri Nov 10 09:19:04 2023 +0100
committer Rene Cordier <rene.cordier@gmail.com> Tue May 14 09:31:22 2024 +0700
tree 889e37844868f409525985a83f1d9e576f081df8
parent 97353a34da05345c142f1daef25cc13c636ca675

JAMES-3955 WARNING logs upon closing channels

backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java

diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java
index a98d11f..10b2d5e 100644
--- a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java
+++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java
@@ -111,6 +111,10 @@
 
         @Override
         public void close(int closeCode, String closeMessage) throws IOException, TimeoutException {
+            // https://www.rabbitmq.com/amqp-0-9-1-reference.html#domain.reply-code
+            if (closeCode >= 300) {
+                LOGGER.warn("Closing channel {} code:{} message:'{}'", getChannelNumber(), closeCode, closeMessage);
+            }
             delegate.close(closeCode, closeMessage);
         }
 
@@ -121,6 +125,10 @@
 
         @Override
         public void abort(int closeCode, String closeMessage) throws IOException {
+            // https://www.rabbitmq.com/amqp-0-9-1-reference.html#domain.reply-code
+            if (closeCode >= 300) {
+                LOGGER.warn("Closing channel {} code:{} message:'{}'", getChannelNumber(), closeCode, closeMessage);
+            }
             delegate.abort(closeCode, closeMessage);
         }