From fb26da1d2c0a4b572d5055a0fa2fe060472c230d Mon Sep 17 00:00:00 2001
From: fangjian0423 <fangjian0423@gmail.com>
Date: Fri, 29 Mar 2019 10:40:11 +0800
Subject: [PATCH] Add default name-server for rmq binder in finchley branch

---
 .../config/RocketMQComponent4BinderAutoConfiguration.java      | 3 +++
 1 file changed, 3 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 e481ac87..1accf35f 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
@@ -67,6 +67,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;
 	}