[rocketmq] branch develop updated: [ISSUE #1574] change GET_ROUTEINTO_BY_TOPIC to GET_ROUTEINFO_BY_TOPIC

[dinglei]

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

dinglei pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new bca05f7  [ISSUE #1574] change GET_ROUTEINTO_BY_TOPIC to 
GET_ROUTEINFO_BY_TOPIC
bca05f7 is described below

commit bca05f7b5ce349717b4cdf820484a46b74217df4
Author: SSpirits <shadowyspir...@outlook.com>
AuthorDate: Mon Mar 30 17:53:33 2020 +0800

    [ISSUE #1574] change GET_ROUTEINTO_BY_TOPIC to GET_ROUTEINFO_BY_TOPIC
    
    [ISSUE #1574] change GET_ROUTEINTO_BY_TOPIC to GET_ROUTEINFO_BY_TOPIC
---
 .../src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java  | 2 +-
 .../src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java  | 2 +-
 .../org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java  | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java 
b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index c7d5a06..643b287 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -1366,7 +1366,7 @@ public class MQClientAPIImpl {
         GetRouteInfoRequestHeader requestHeader = new 
GetRouteInfoRequestHeader();
         requestHeader.setTopic(topic);
 
-        RemotingCommand request = 
RemotingCommand.createRequestCommand(RequestCode.GET_ROUTEINTO_BY_TOPIC, 
requestHeader);
+        RemotingCommand request = 
RemotingCommand.createRequestCommand(RequestCode.GET_ROUTEINFO_BY_TOPIC, 
requestHeader);
 
         RemotingCommand response = this.remotingClient.invokeSync(null, 
request, timeoutMillis);
         assert response != null;
diff --git 
a/common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java 
b/common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java
index b3009d7..75ceff3 100644
--- a/common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java
+++ b/common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java
@@ -89,7 +89,7 @@ public class RequestCode {
     public static final int REGISTER_BROKER = 103;
 
     public static final int UNREGISTER_BROKER = 104;
-    public static final int GET_ROUTEINTO_BY_TOPIC = 105;
+    public static final int GET_ROUTEINFO_BY_TOPIC = 105;
 
     public static final int GET_BROKER_CLUSTER_INFO = 106;
     public static final int UPDATE_AND_CREATE_SUBSCRIPTIONGROUP = 200;
diff --git 
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
 
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
index 7210246..d62be47 100644
--- 
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
+++ 
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
@@ -97,7 +97,7 @@ public class DefaultRequestProcessor extends 
AsyncNettyRequestProcessor implemen
                 }
             case RequestCode.UNREGISTER_BROKER:
                 return this.unregisterBroker(ctx, request);
-            case RequestCode.GET_ROUTEINTO_BY_TOPIC:
+            case RequestCode.GET_ROUTEINFO_BY_TOPIC:
                 return this.getRouteInfoByTopic(ctx, request);
             case RequestCode.GET_BROKER_CLUSTER_INFO:
                 return this.getBrokerClusterInfo(ctx, request);