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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
