You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2020/04/17 00:32:24 UTC
[james-project] 32/39: JAMES-3139 Decrease the hard coded retries
before opening a RabbitMQ connection
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 f6308a32a2573a4fb0cc40e7b1d7ec478f027bd6
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Thu Apr 16 10:01:00 2020 +0700
JAMES-3139 Decrease the hard coded retries before opening a RabbitMQ connection
100 backed of retries is too long, we should fail faster, as failure is
handled upstream.
---
.../java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java
index 6aa1ba5..f4fa4e1 100644
--- a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java
+++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/SimpleConnectionPool.java
@@ -54,7 +54,7 @@ public class SimpleConnectionPool implements AutoCloseable {
}
public Mono<Connection> getResilientConnection() {
- int numRetries = 100;
+ int numRetries = 10;
Duration initialDelay = Duration.ofMillis(100);
Duration forever = Duration.ofMillis(Long.MAX_VALUE);
return Mono.defer(this::getOpenConnection)
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org