You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2022/05/31 08:07:13 UTC
[james-project] 02/02: JAMES-3772 ReactorRabbitMQChannelPool: get rid of asynchronous release
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 8f0e4d0980ed5df759a9e7035e005b549b1e5449
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Mon May 30 10:45:29 2022 +0700
JAMES-3772 ReactorRabbitMQChannelPool: get rid of asynchronous release
---
.../org/apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java | 2 --
1 file changed, 2 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 2f255c0592..6167f2740d 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
@@ -731,12 +731,10 @@ public class ReactorRabbitMQChannelPool implements ChannelPool, Startable {
if (!channel.isOpen() || !executeWithoutError(signalType)) {
pooledRef.invalidate()
- .subscribeOn(Schedulers.elastic())
.subscribe();
return;
}
pooledRef.release()
- .subscribeOn(Schedulers.elastic())
.subscribe();
});
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org