fix(retry): send message back failed some time because timeout set to…

… short. (#283)
apache · Mar 19, 2020 · aee285f · aee285f
1 parent f7c0a1a
commit aee285f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/consumer/DefaultMQPushConsumerImpl.cpp b/src/consumer/DefaultMQPushConsumerImpl.cpp
@@ -259,8 +259,8 @@ bool DefaultMQPushConsumerImpl::sendMessageBack(MQMessageExt& msg, int delayLeve
   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;