REQ-2481: 添加删除日志表的job

2024-05-31 15:27:07 +08:00 · 2024-05-31 15:27:07 +08:00 · 4ad9595c8d
commit 4ad9595c8d
parent 024ce3dca5
1 changed files with 2 additions and 0 deletions
--- a/im-center-server/src/main/java/cn/axzo/im/send/SendQueue.java
+++ b/im-center-server/src/main/java/cn/axzo/im/send/SendQueue.java
@ -111,6 +111,8 @@ public class SendQueue {
                    .computeIfAbsent(batchNo, unused -> new ArrayList<>());
            batchRecords.add(record);
        }
+        if (batchNo2Records.isEmpty())
+            return Collections.emptyList();
        List<List<Record>> groups = new ArrayList<>(batchNo2Records.values());
        groups.sort(Comparator.comparingInt(List::size));
        // a batch that has max records