(rocketmq) branch develop updated: [ISSUE #8824] Fix IllegalStateException caused by logical errors (#8825)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new a7dc023589 [ISSUE #8824] Fix IllegalStateException caused by logical 
errors (#8825)
a7dc023589 is described below

commit a7dc0235890641e23c65a9517c4800f989b85142
Author: yx9o <yangx_s...@163.com>
AuthorDate: Wed Oct 16 11:00:51 2024 +0800

    [ISSUE #8824] Fix IllegalStateException caused by logical errors (#8825)
---
 .../src/main/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 bca2d79d99..c8b404dd69 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 class RpcClientImpl implements RpcClient {
                             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);