[james-project] branch master updated: Move rabbitMQ channel close operation to boundedElastic thread (#1639)

[btellier]

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


The following commit(s) were added to refs/heads/master by this push:
     new 3011d23f9a Move rabbitMQ channel close operation to boundedElastic 
thread (#1639)
3011d23f9a is described below

commit 3011d23f9a2837e245a2616391168f51f765f195
Author: Arooba Shahoor <56495631+arooba-...@users.noreply.github.com>
AuthorDate: Mon Jul 10 10:59:35 2023 +0900

    Move rabbitMQ channel close operation to boundedElastic thread (#1639)
    
    This prevents the call from blocking the reactive pipeline
---
 .../apache/james/backends/rabbitmq/ReactorRabbitMQChannelPool.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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..80368108ca 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
@@ -685,7 +685,9 @@ public class ReactorRabbitMQChannelPool implements 
ChannelPool, Startable {
                 if (channel.isOpen()) {
                     channel.close();
                 }
-            })))
+            }))
+            .then()
+            .subscribeOn(Schedulers.boundedElastic()))
             .buildPool();
     }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org