mirror of
https://gitee.com/mirrors/Spring-Cloud-Alibaba.git
synced 2021-06-26 13:25:11 +08:00
fix NPE
This commit is contained in:
parent
78985d45a5
commit
f1d522be50
@ -199,6 +199,7 @@ public class RocketMQMessageChannelBinder extends
|
||||
consumerProperties.getExtension().getDelayLevelWhenNextConsume());
|
||||
listenerContainer
|
||||
.setNameServer(rocketBinderConfigurationProperties.getNameServer());
|
||||
listenerContainer.setHeaderMapper(createHeaderMapper(consumerProperties));
|
||||
|
||||
RocketMQInboundChannelAdapter rocketInboundChannelAdapter = new RocketMQInboundChannelAdapter(
|
||||
listenerContainer, consumerProperties, instrumentationManager);
|
||||
|
Loading…
x
Reference in New Issue
Block a user