Fix grpc status equals (#709)

apache · Mar 18, 2024 · fe3805c · fe3805c
1 parent 3036b04
commit fe3805c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java b/.../client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java
@@ -271,7 +271,7 @@ public void onFailure(Throwable t) {
                     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();
                         }
                     }