From a7dc0235890641e23c65a9517c4800f989b85142 Mon Sep 17 00:00:00 2001
From: yx9o <yangx_soft@163.com>
Date: Wed, 16 Oct 2024 11:00:51 +0800
Subject: [PATCH] [ISSUE #8824] Fix IllegalStateException caused by logical
 errors (#8825)

---
 .../java/org/apache/rocketmq/remoting/rpc/RpcClientImpl.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientImpl.java b/remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientImpl.java
index bca2d79d995..c8b404dd696 100644
--- a/remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientImpl.java
+++ b/remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientImpl.java
@@ -174,6 +174,7 @@ public void operationSucceed(RemotingCommand response) {
                             PullMessageResponseHeader responseHeader =
                                 (PullMessageResponseHeader) response.decodeCommandCustomHeader(PullMessageResponseHeader.class);
                             rpcResponsePromise.setSuccess(new RpcResponse(response.getCode(), responseHeader, response.getBody()));
+                            break;
                         default:
                             RpcResponse rpcResponse = new RpcResponse(new RpcException(response.getCode(), "unexpected remote response code"));
                             rpcResponsePromise.setSuccess(rpcResponse);