From f18d4a025ab09d1c8e6fc286ba634f79f2019250 Mon Sep 17 00:00:00 2001 From: yanglin Date: Thu, 6 Feb 2025 10:51:54 +0800 Subject: [PATCH] =?UTF-8?q?REQ-3345:=20=E8=AE=BE=E7=BD=AE=E7=BE=A4?= =?UTF-8?q?=E4=B8=8A=E9=99=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- im-center-server/src/main/java/cn/axzo/im/group/GroupProps.java | 2 +- .../main/java/cn/axzo/im/group/message/GroupMessageSyncJob.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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())); }