fix(retry): send message back failed some time because timeout set to short. (#283)
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;