-
Notifications
You must be signed in to change notification settings - Fork 166
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
BUG REPORT
- Please describe the issue you observed:
- What did you do (The steps to reproduce)?
To push consumers, set consume messages status to RECONSUME_LATER always. - What did you expect to see?
messages were sent to the broker, and consume again later. - What did you see instead?
sometimes, sent message back failed, time out exception thow.
- Please tell us about your environment:
- What is your OS?
MacOS - What is your client version?
2.0.1 - What is your RocketMQ version?
4.6.0
- Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
string brokerAddr;
if (!brokerName.empty())
brokerAddr = getFactory()->findBrokerAddressInPublish(brokerName);
else
brokerAddr = socketAddress2IPPort(msg.getStoreHost());
try {
getFactory()->getMQClientAPIImpl()->consumerSendMessageBack(brokerAddr, msg, getGroupName(), delayLevel, 3000,
getMaxReconsumeTimes(), getSessionCredentials());
} catch (MQException& e) {
LOG_ERROR(e.what());
return false;
}
return true;
}
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working