[rocketmq]fix variable judgment bug

pull/2258/head
panzhi33 3 years ago
parent c501697bc8
commit bbf4977e7e

@ -74,7 +74,7 @@ public class RocketMQComponent4BinderAutoConfiguration {
configNameServer = RocketMQBinderConstants.DEFAULT_NAME_SERVER;
}
producer.setNamesrvAddr(configNameServer);
if (!StringUtils.isEmpty(configNameServer)) {
if (!StringUtils.isEmpty(accessChannel)) {
producer.setAccessChannel(AccessChannel.valueOf(accessChannel));
}
return producer;

Loading…
Cancel
Save