fix issue #138

Signed-off-by: Keli <[email protected]>
qunarcorp · Jul 11, 2021 · 4fc8781 · 4fc8781
1 parent 22d6917
commit 4fc8781
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/qmq-remoting/src/main/java/qunar/tc/qmq/metainfoclient/MetaInfoService.java b/qmq-remoting/src/main/java/qunar/tc/qmq/metainfoclient/MetaInfoService.java
@@ -124,15 +124,15 @@ private void request(MetaInfoRequestParam param) {
         request.setClientId(this.clientId);
         request.setConsumerGroup(param.group);
         request.setAppCode(param.getAppCode());
-        request.setRequestType(param.getRequestType());
 
         if (param.getRequestType() == null) {
             if (!hadOnline(param)) {
                 request.setRequestType(ClientRequestType.ONLINE);
-            }
-            else {
+            } else {
                 request.setRequestType(ClientRequestType.HEARTBEAT);
             }
+        } else {
+            request.setRequestType(param.getRequestType());
         }
 
         LOGGER.debug("meta info request: {}", request);