You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2023/02/28 00:17:24 UTC
[rocketmq] branch develop updated: [ISSUE #6131] Simplified ConsumeReviveObj code (#6132)
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 84ed06158 [ISSUE #6131] Simplified ConsumeReviveObj code (#6132)
84ed06158 is described below
commit 84ed06158a47b213885ab94374c9f19bb65c22ef
Author: hardyfish <85...@users.noreply.github.com>
AuthorDate: Tue Feb 28 08:17:16 2023 +0800
[ISSUE #6131] Simplified ConsumeReviveObj code (#6132)
* simplified ConsumeReviveObj code
* remove useless import
---
.../org/apache/rocketmq/broker/processor/PopReviveService.java | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
index f451c6047..a63cd2930 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
@@ -21,7 +21,6 @@ import io.opentelemetry.api.common.Attributes;
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.Collections;
-import java.util.Comparator;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -651,12 +650,7 @@ public class PopReviveService extends ServiceThread {
return sortList;
}
sortList = new ArrayList<>(map.values());
- Collections.sort(sortList, new Comparator<PopCheckPoint>() {
- @Override
- public int compare(PopCheckPoint o1, PopCheckPoint o2) {
- return (int) (o1.getReviveOffset() - o2.getReviveOffset());
- }
- });
+ sortList.sort((o1, o2) -> (int) (o1.getReviveOffset() - o2.getReviveOffset()));
return sortList;
}
}