[rocketmq] branch develop updated: [ISSUE #6131] Simplified ConsumeReviveObj code (#6132)

[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 84ed06158 [ISSUE #6131] Simplified ConsumeReviveObj code (#6132)
84ed06158 is described below

commit 84ed06158a47b213885ab94374c9f19bb65c22ef
Author: hardyfish <85128645+hardyf...@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;
         }
     }