[rocketmq-client-cpp] branch master updated: fix(retry): send message back failed some time because timeout set to short. (#283)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git


The following commit(s) were added to refs/heads/master by this push:
     new aee285f  fix(retry): send message back failed some time because 
timeout set to short. (#283)
aee285f is described below

commit aee285fa1948d15cc1c6a70109a151bd044bc51a
Author: dinglei <libya_...@163.com>
AuthorDate: Thu Mar 19 20:48:31 2020 +0800

    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 c503804..36c421c 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;