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/03/21 04:54:58 UTC
[james-project] 02/03: [PERF] Naming threads: RabbitMQ driver threads should be named
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 929e95d42cf545be25d3672f63868b24b9245144
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Fri Mar 18 11:09:48 2022 +0700
[PERF] Naming threads: RabbitMQ driver threads should be named
---
.../org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java
index 349bb82..140618c 100644
--- a/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java
+++ b/backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQConnectionFactory.java
@@ -39,6 +39,7 @@ import javax.net.ssl.SSLContext;
import org.apache.commons.lang3.NotImplementedException;
import org.apache.http.ssl.SSLContextBuilder;
import org.apache.http.ssl.TrustStrategy;
+import org.apache.james.util.concurrent.NamedThreadFactory;
import com.google.common.collect.ImmutableList;
import com.rabbitmq.client.Address;
@@ -66,6 +67,7 @@ public class RabbitMQConnectionFactory {
private ConnectionFactory from(RabbitMQConfiguration rabbitMQConfiguration) {
try {
ConnectionFactory connectionFactory = new ConnectionFactory();
+ connectionFactory.setThreadFactory(NamedThreadFactory.withName("rabbitmq-driver"));
connectionFactory.setUri(rabbitMQConfiguration.getUri());
connectionFactory.setHandshakeTimeout(rabbitMQConfiguration.getHandshakeTimeoutInMs());
connectionFactory.setShutdownTimeout(rabbitMQConfiguration.getShutdownTimeoutInMs());
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org