From aee285fa1948d15cc1c6a70109a151bd044bc51a Mon Sep 17 00:00:00 2001 From: dinglei Date: Thu, 19 Mar 2020 20:48:31 +0800 Subject: [PATCH] fix(retry): send message back failed some time because timeout set to short. (#283) --- src/consumer/DefaultMQPushConsumerImpl.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/consumer/DefaultMQPushConsumerImpl.cpp b/src/consumer/DefaultMQPushConsumerImpl.cpp index c5038046b..36c421c62 100644 --- 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;