diff --git a/im-center-server/src/main/java/cn/axzo/im/group/GroupProps.java b/im-center-server/src/main/java/cn/axzo/im/group/GroupProps.java index 993a9b2..77ad054 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/GroupProps.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/GroupProps.java @@ -16,7 +16,7 @@ import org.springframework.context.annotation.Configuration; public class GroupProps { public int defaultMemberLimit = 499; - public int syncMessageType = 20; + public int syncMessageTps = 20; @Override public String toString() { diff --git a/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncJob.java b/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncJob.java index 3386a0d..3193f68 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncJob.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncJob.java @@ -125,7 +125,7 @@ public class GroupMessageSyncJob implements InitializingBean { @Override public void afterPropertiesSet() { - tps = groupProps.syncMessageType; + tps = groupProps.syncMessageTps; executor = Executors.newFixedThreadPool( tps + 1, new NamedThreadFactory(GroupMessageSyncJob.class.getName())); }