未验证 提交 74aa3e00 编写于 作者: H Heng Du 提交者: GitHub

Update SendMessageProcessor.java

上级 bc3eeed4
...@@ -179,7 +179,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement ...@@ -179,7 +179,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
int maxReconsumeTimes = subscriptionGroupConfig.getRetryMaxTimes(); int maxReconsumeTimes = subscriptionGroupConfig.getRetryMaxTimes();
if (request.getVersion() >= MQVersion.Version.V3_4_9.ordinal()) { if (request.getVersion() >= MQVersion.Version.V3_4_9.ordinal()) {
Integer times = requestHeader.getMaxReconsumeTimes(); Integer times = requestHeader.getMaxReconsumeTimes();
if (times != null){ if (times != null) {
maxReconsumeTimes = times; maxReconsumeTimes = times;
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册