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

REQ-3345: 同步消息

Browse Source
This commit is contained in:
yanglin 2025-01-23 18:10:56 +08:00
parent 2b594a6b54
commit a995b7e361
2 changed files with 4 additions and 4 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/group/message/GroupMessageSyncService.java
View File

@ -75,7 +75,7 @@ public class GroupMessageSyncService {
.gt(Group::getDismissedAt, twoDayAgo))));
for (List<Group> groups : cursor) {
for (Group group : groups) {
controller.acquireSubmitGroup(group);
controller.submitGroup(group);
executor.execute(new GroupMessageSyncer(this, controller, group) {
@Override
public void run() {
@ -84,7 +84,7 @@ public class GroupMessageSyncService {
} catch (Exception e) {
log.warn("sync group message failed: {}", group.getId(), e);
} finally {
controller.setGroupCompleted(group);
controller.completeGroup(group);
}
}
});

4
im-center-server/src/main/java/cn/axzo/im/group/message/MessageSyncController.java
View File

@ -33,7 +33,7 @@ class MessageSyncController {
this.onComplete = onComplete;
}
void acquireSubmitGroup(Group group) throws Exception {
void submitGroup(Group group) throws Exception {
submitGroupSemaphore.acquire();
Object submitted = groups.putIfAbsent(group.getId(), SUBMITTED);
if (submitted != null) {
@ -48,7 +48,7 @@ class MessageSyncController {
log.info("submitted group: {}", group.getId());
}
void setGroupCompleted(Group group) {
void completeGroup(Group group) {
Object submitted = groups.remove(group.getId());
if (submitted == null) return;
submitGroupSemaphore.release();