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 77ad054..e026657 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 @@ -1,6 +1,7 @@ package cn.axzo.im.group; import com.alibaba.fastjson.JSON; +import lombok.Getter; import lombok.Setter; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.cloud.context.config.annotation.RefreshScope; @@ -10,13 +11,14 @@ import org.springframework.context.annotation.Configuration; * @author yanglin */ @Setter +@Getter @RefreshScope @Configuration @ConfigurationProperties(prefix = "im-group") public class GroupProps { - public int defaultMemberLimit = 499; - public int syncMessageTps = 20; + private int defaultMemberLimit = 499; + private int syncMessageTps = 20; @Override public String toString() { diff --git a/im-center-server/src/main/java/cn/axzo/im/group/GroupSupport.java b/im-center-server/src/main/java/cn/axzo/im/group/GroupSupport.java index d3e7012..b7929bd 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/GroupSupport.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/GroupSupport.java @@ -38,7 +38,8 @@ public class GroupSupport implements GroupLogger { group.setAvatar(request.getAvatar()); group.setMemberCount((long) request.getOwnerAndMembers().size()); Long memberLimit = request.getMemberLimit(); - group.setMemberLimit(memberLimit == null ? groupProps.defaultMemberLimit : memberLimit); + group.setMemberLimit(memberLimit == null + ? groupProps.getDefaultMemberLimit() : memberLimit); group.setOwnerAccount(owner); group.setOwnerPersonId(request.getOwner().personIdAsLong()); group.setCreatePersonId(request.getOwner().personIdAsLong()); 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 3193f68..6f42d88 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.syncMessageTps; + tps = groupProps.getSyncMessageTps(); executor = Executors.newFixedThreadPool( tps + 1, new NamedThreadFactory(GroupMessageSyncJob.class.getName())); }