(rocketmq-clients) branch master updated: Fix grpc status equals (#709)

[lizhanhui]

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

lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new fe3805cb Fix grpc status equals (#709)
fe3805cb is described below

commit fe3805cbe959aad61e4cc43c3fb76135fd550320
Author: Liu Shengzhong <szliu0...@gmail.com>
AuthorDate: Mon Mar 18 14:09:52 2024 +0800

    Fix grpc status equals (#709)
---
 .../org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java
index c43b4a10..56b18a22 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java
@@ -271,7 +271,7 @@ class ProcessQueueImpl implements ProcessQueue {
                     String nextAttemptId = null;
                     if (t instanceof StatusRuntimeException) {
                         StatusRuntimeException exception = 
(StatusRuntimeException) t;
-                        if 
(io.grpc.Status.DEADLINE_EXCEEDED.equals(exception.getStatus())) {
+                        if (io.grpc.Status.DEADLINE_EXCEEDED.getCode() == 
exception.getStatus().getCode()) {
                             nextAttemptId = request.getAttemptId();
                         }
                     }