You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by rc...@apache.org on 2024/05/14 02:31:18 UTC
(james-project) 03/05: JAMES-3955 WARNING logs upon closing channels
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch 3.8.x
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 040601a767cd96e5ec72a285be108754d6f019e6
Author: Benoit TELLIER <bt...@linagora.com>
AuthorDate: Fri Nov 10 09:19:04 2023 +0100
JAMES-3955 WARNING logs upon closing channels
---
.../james/backends/rabbitmq/ReactorRabbitMQChannelPool.java | 8 ++++++++
1 file changed, 8 insertions(+)
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 fc65f6b1d6..f465eb0262 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
@@ -110,6 +110,10 @@ public class ReactorRabbitMQChannelPool implements ChannelPool, Startable {
@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);
}
@@ -120,6 +124,10 @@ public class ReactorRabbitMQChannelPool implements ChannelPool, Startable {
@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);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org