Browse Source

feat(rabbit):连接池增加host参数

hejq 7 years ago
parent
commit
338a111026

+ 1 - 0
src/main/java/com/uas/platform/b2b/support/mq/config/RabbitMqConfig.java

@@ -76,6 +76,7 @@ public class RabbitMqConfig {
     public ConnectionFactory connectionFactory() {
         CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
         connectionFactory.setAddresses(this.host);
+        connectionFactory.setHost(this.host);
         connectionFactory.setPort(this.port);
         connectionFactory.setUsername(this.username);
         connectionFactory.setPassword(this.password);