wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
yanglin 2024-05-31 15:14:29 +08:00
parent a795f88ada
commit a68c8ada79
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
im-center-server/src/main/java/cn/axzo/im/send/SendQueue.java
View File

@ -72,7 +72,7 @@ public class SendQueue {
.collect(toList());
}
// 批量最大的优先, 不要浪费批量接口的流量
List<Record> perfectRecords = getQueuedMaxBatch();
List<Record> perfectRecords = determineQueuedMaxBatch();
// 如果没有真正的批量, 就退回到按优先级顺序发送
if (perfectRecords.size() <= 1) {
MessageHistory history = poll().orElse(null);
@ -106,7 +106,7 @@ public class SendQueue {
return histories;
}
private List<Record> getQueuedMaxBatch() {
private List<Record> determineQueuedMaxBatch() {
Map<String, List<Record>> batchNo2Records = new HashMap<>();
for (Record record : records) {
String batchNo = record.history.determineBatchNo().orElse(null);