You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by if...@apache.org on 2020/12/29 03:36:44 UTC
[rocketmq-client-cpp] 27/29: style: fix GET_ROUTEINFO_BY_TOPIC
This is an automated email from the ASF dual-hosted git repository.
ifplusor pushed a commit to branch re_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git
commit 4ace548e2af6efb013a016c539e3ffa2f93b85e6
Author: James Yin <yw...@hotmail.com>
AuthorDate: Wed Oct 21 13:02:24 2020 +0800
style: fix GET_ROUTEINFO_BY_TOPIC
---
src/MQClientAPIImpl.cpp | 2 +-
src/protocol/RequestCode.h | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/MQClientAPIImpl.cpp b/src/MQClientAPIImpl.cpp
index 2d35354..b25f672 100644
--- a/src/MQClientAPIImpl.cpp
+++ b/src/MQClientAPIImpl.cpp
@@ -634,7 +634,7 @@ void MQClientAPIImpl::unlockBatchMQ(const std::string& addr,
}
TopicRouteData* MQClientAPIImpl::getTopicRouteInfoFromNameServer(const std::string& topic, int timeoutMillis) {
- RemotingCommand request(GET_ROUTEINTO_BY_TOPIC, new GetRouteInfoRequestHeader(topic));
+ RemotingCommand request(GET_ROUTEINFO_BY_TOPIC, new GetRouteInfoRequestHeader(topic));
std::unique_ptr<RemotingCommand> response(remoting_client_->invokeSync(null, request, timeoutMillis));
assert(response != nullptr);
diff --git a/src/protocol/RequestCode.h b/src/protocol/RequestCode.h
index 68b8f31..40180dd 100644
--- a/src/protocol/RequestCode.h
+++ b/src/protocol/RequestCode.h
@@ -122,7 +122,7 @@ enum MQRequestCode {
DELETE_KV_CONFIG = 102,
REGISTER_BROKER = 103,
UNREGISTER_BROKER = 104,
- GET_ROUTEINTO_BY_TOPIC = 105,
+ GET_ROUTEINFO_BY_TOPIC = 105,
GET_BROKER_CLUSTER_INFO = 106,
WIPE_WRITE_PERM_OF_BROKER = 205,
GET_ALL_TOPIC_LIST_FROM_NAMESERVER = 206,