This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/master by this push:
new 2674b2de72 [ENHANCEMENT] Remove benign verbose logs upon shutdown
(#2356)
2674b2de72 is described below
commit 2674b2de724cac0c0dfeb1e2932aec15bf7e3834
Author: Benoit TELLIER <[email protected]>
AuthorDate: Mon Jul 22 05:35:07 2024 +0200
[ENHANCEMENT] Remove benign verbose logs upon shutdown (#2356)
---
.../james/backends/rabbitmq/ReactorRabbitMQChannelPool.java | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
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 8560035121..3a29c01a7c 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
@@ -693,7 +693,11 @@ public class ReactorRabbitMQChannelPool implements
ChannelPool, Startable {
})
.destroyHandler(channel -> Mono.fromRunnable(Throwing.runnable(()
-> {
if (channel.isOpen()) {
- channel.close();
+ try {
+ channel.close();
+ } catch (ShutdownSignalException e) {
+ // silent this error
+ }
}
}))
.then()
@@ -814,9 +818,9 @@ public class ReactorRabbitMQChannelPool implements
ChannelPool, Startable {
@Override
public void close() {
sender.close();
- Flux.fromIterable(refs.values())
- .flatMap(PooledRef::invalidate)
- .blockLast();
+ Flux.fromIterable(refs.values())
+ .flatMap(PooledRef::invalidate)
+ .blockLast();
refs.clear();
newPool.dispose();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
