diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index b2edc1a20f39cbeb94d4f1356737aac49efc664a..2b077cbb13ac46f0f1bb0421f09f95d3c31cd31a 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -1493,11 +1493,9 @@ public class AdminBrokerProcessor implements NettyRequestProcessor {
             response.setRemark(String.format("%d@%s is not exist!", requestHeader.getQueueId(), requestHeader.getTopic()));
             return response;
         }
-
-        QueryConsumeQueueResponseBody body = new QueryConsumeQueueResponseBody();
         response.setCode(ResponseCode.SUCCESS);
-        response.setBody(body.encode());
 
+        QueryConsumeQueueResponseBody body = new QueryConsumeQueueResponseBody();
         body.setMaxQueueIndex(consumeQueue.getMaxOffsetInQueue());
         body.setMinQueueIndex(consumeQueue.getMinOffsetInQueue());
 
@@ -1556,7 +1554,7 @@ public class AdminBrokerProcessor implements NettyRequestProcessor {
         } finally {
             result.release();
         }
-
+        response.setBody(body.encode());
         return response;
     }