commit aee285fa1948d15cc1c6a70109a151bd044bc51a
author dinglei <libya_003@163.com> Thu Mar 19 20:48:31 2020 +0800
committer GitHub <noreply@github.com> Thu Mar 19 20:48:31 2020 +0800
tree 5eadf9430dbd41feb108b0a50d6ddf7c168e45ec
parent f7c0a1a3ffb457f75b234fc2248b13683bcdffee

fix(retry): send message back failed some time because timeout set to short. (#283)

src/consumer/DefaultMQPushConsumerImpl.cpp

diff --git a/src/consumer/DefaultMQPushConsumerImpl.cpp b/src/consumer/DefaultMQPushConsumerImpl.cpp
index c503804..36c421c 100644
--- a/src/consumer/DefaultMQPushConsumerImpl.cpp
+++ b/src/consumer/DefaultMQPushConsumerImpl.cpp
@@ -259,8 +259,8 @@
   else
     brokerAddr = socketAddress2IPPort(msg.getStoreHost());
   try {
-    getFactory()->getMQClientAPIImpl()->consumerSendMessageBack(brokerAddr, msg, getGroupName(), delayLevel,
-                                                                getMaxReconsumeTimes(), 3000, getSessionCredentials());
+    getFactory()->getMQClientAPIImpl()->consumerSendMessageBack(brokerAddr, msg, getGroupName(), delayLevel, 3000,
+                                                                getMaxReconsumeTimes(), getSessionCredentials());
   } catch (MQException& e) {
     LOG_ERROR(e.what());
     return false;