SpringCloud/spring-cloud-connectors
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update RabbitConnectionFactoryCreator to set setAutomaticRecoveryEnabled equal to false

Browse Source
This commit is contained in:
bk016677
2018-08-22 21:16:00 -05:00
parent cc1e77e59e
commit f5977ed4d6
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-spring-service-connector/src/main/java/org/springframework/cloud/service/messaging/RabbitConnectionFactoryCreator.java
View File

@@ -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 {