Skip to content

Commit a7092e1

Browse files
committed
refactor(rocketmq-spring-boot): 优化 RocketMQMessageHandler 默认实现
- 为 rocketMQMessageHandler 添加默认实现,提高代码健壮性
1 parent 9e9d488 commit a7092e1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ public class DefaultRocketMQListenerContainer implements InitializingBean,
140140

141141
private String instanceName;
142142

143-
private RocketMQMessageHandler rocketMQMessageHandler;
143+
private RocketMQMessageHandler rocketMQMessageHandler = (message, chain) -> chain.doHandler(message);
144144

145145
public long getSuspendCurrentQueueTimeMillis() {
146146
return suspendCurrentQueueTimeMillis;

0 commit comments

Comments
 (0)