diff --git a/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncService.java b/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncService.java index 888f316..64a5b49 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncService.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncService.java @@ -70,7 +70,7 @@ public class GroupMessageSyncService { for (List groups : cursor) { for (Group group : groups) { controller.submitGroup(group); - executor.execute(new GroupMessageSyncer(this, controller, group) { + executor.execute(new GroupMessageSyncHandler(this, controller, group) { @Override public void run() { try {