From 507bcdb6fa9f4cb79657d494a8c76f1b5f988fc3 Mon Sep 17 00:00:00 2001 From: fangjian0423 Date: Fri, 29 Mar 2019 10:46:05 +0800 Subject: [PATCH] Add default name-server for rmq binder in 1.x branch --- .../config/RocketMQComponent4BinderAutoConfiguration.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java index 407ef1d7..0a284310 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java @@ -31,6 +31,7 @@ import org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.env.Environment; +import org.springframework.util.StringUtils; import com.fasterxml.jackson.databind.ObjectMapper; @@ -67,6 +68,9 @@ public class RocketMQComponent4BinderAutoConfiguration { else { producer = new DefaultMQProducer(RocketMQBinderConstants.DEFAULT_GROUP); } + if (StringUtils.isEmpty(configNameServer)) { + configNameServer = RocketMQBinderConstants.DEFAULT_NAME_SERVER; + } producer.setNamesrvAddr(configNameServer); return producer; }