jonnxu commented on a change in pull request #48: [Issue#44] Resolve
RetrySendTimes doesn't Work for Async Send
URL: https://github.com/apache/rocketmq-client-cpp/pull/48#discussion_r245183701
##########
File path: src/transport/ResponseFuture.cpp
##########
@@ -164,6 +171,39 @@ bool ResponseFuture::isTimeOut() const {
return m_bAsync.load() == 1 && diff > m_timeout;
}
+int ResponseFuture::getMaxRetrySendTimes() const {
+ return m_maxRetrySendTimes;
+}
+int ResponseFuture::getRetrySendTimes() const {
+ return m_retrySendTimes;
+}
+
+void ResponseFuture::setMaxRetrySendTimes(int maxRetryTimes) {
+ m_maxRetrySendTimes = maxRetryTimes;
+}
+void ResponseFuture::setRetrySendTimes(int retryTimes) {
+ m_retrySendTimes = retryTimes;
+}
+
+void ResponseFuture::setBrokerAddr(const std::string& brokerAddr) {
+ m_brokerAddr = brokerAddr;
+}
+void ResponseFuture::setRequestCommand(const RemotingCommand& requestCommand) {
+ m_requestCommand = requestCommand;
+}
+
+const RemotingCommand& ResponseFuture::getRequestCommand() {
+ return m_requestCommand;
+}
+std::string ResponseFuture::getBrokerAddr() const {
+ return m_brokerAddr;
+}
+
+int64 ResponseFuture::leftTime() const {
Review comment:
it doesn't matter
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
