[ISSUE #8824] Fix IllegalStateException caused by logical errors (#8825)

apache · Oct 16, 2024 · a7dc023 · a7dc023
1 parent 2fa7513
commit a7dc023
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -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);