Skip to content

Send message back failed some time because timeout set to short. #282

@ShannonDing

Description

@ShannonDing

BUG REPORT

  1. 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.
  1. 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
  1. 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 working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions