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;