From f5977ed4d6b1ea2791b1476004bd3a969c8367ec Mon Sep 17 00:00:00 2001 From: bk016677 Date: Wed, 22 Aug 2018 21:16:00 -0500 Subject: [PATCH] Update RabbitConnectionFactoryCreator to set setAutomaticRecoveryEnabled equal to false --- .../cloud/service/messaging/RabbitConnectionFactoryCreator.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spring-cloud-spring-service-connector/src/main/java/org/springframework/cloud/service/messaging/RabbitConnectionFactoryCreator.java b/spring-cloud-spring-service-connector/src/main/java/org/springframework/cloud/service/messaging/RabbitConnectionFactoryCreator.java index 8141b30..ed8c98a 100644 --- a/spring-cloud-spring-service-connector/src/main/java/org/springframework/cloud/service/messaging/RabbitConnectionFactoryCreator.java +++ b/spring-cloud-spring-service-connector/src/main/java/org/springframework/cloud/service/messaging/RabbitConnectionFactoryCreator.java @@ -38,6 +38,8 @@ public class RabbitConnectionFactoryCreator extends AbstractServiceConnectorCrea private com.rabbitmq.client.ConnectionFactory createRabbitConnectionFactory(AmqpServiceInfo serviceInfo) { com.rabbitmq.client.ConnectionFactory connectionFactory = new com.rabbitmq.client.ConnectionFactory(); + connectionFactory.setAutomaticRecoveryEnabled(false); + if (serviceInfo.getUris() != null && serviceInfo.getUris().size() > 0) { setConnectionFactoryUri(connectionFactory, serviceInfo.getUris().get(0)); } else {