You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2024/03/18 06:09:57 UTC
(rocketmq-clients) branch master updated: Fix grpc status equals (#709)
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 <sz...@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();
}
}