From 4fc8781ef8dfe09eeac72a5e1fae378c39502de0 Mon Sep 17 00:00:00 2001
From: Keli <root@keli.im>
Date: Sun, 11 Jul 2021 17:15:11 +0800
Subject: [PATCH] fix issue #138

Signed-off-by: Keli <root@keli.im>
---
 .../java/qunar/tc/qmq/metainfoclient/MetaInfoService.java   | 6 +++---
 1 file changed, 3 insertions(+), 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
index 913095f4..7fb52ae2 100644
--- 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);