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 2022/05/25 10:26:11 UTC
[james-project] 01/01: JAMES-3772 Fixing a blocking thread issue with reactive RabbitMQ when releasing a channel in the pool
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch bug-rabbitmq-reactor-block
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit ac53248e3ce56ed73f0465c9dcf63a5f7d981bc1
Author: Rene Cordier <rc...@linagora.com>
AuthorDate: Wed May 25 17:22:50 2022 +0700
JAMES-3772 Fixing a blocking thread issue with reactive RabbitMQ when releasing a channel in the pool
---
.../org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java | 2 ++
1 file changed, 2 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 218f375674..c18a9c091b 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
@@ -728,10 +728,12 @@ public class ReactorRabbitMQChannelPool implements ChannelPool, Startable {
if (!channel.isOpen() || !executeWithoutError(signalType)) {
pooledRef.invalidate()
+ .subscribeOn(Schedulers.elastic())
.block();
return;
}
pooledRef.release()
+ .subscribeOn(Schedulers.elastic())
.block();
});
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org