diff --git a/im-center-server/src/main/java/cn/axzo/im/group/support/GroupProps.java b/im-center-server/src/main/java/cn/axzo/im/group/support/GroupProps.java index e771a12..530992e 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/support/GroupProps.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/support/GroupProps.java @@ -26,6 +26,7 @@ public class GroupProps { private int removeMemberTps = 15; private int getGroupInfoTps = 15; private int changeOwnerTps = 15; + private double tpsTooLowWarnWaitSeconds = 1.5; @Override public String toString() { diff --git a/im-center-server/src/main/java/cn/axzo/im/group/support/GroupRateLimiter.java b/im-center-server/src/main/java/cn/axzo/im/group/support/GroupRateLimiter.java index d4fc7fb..8681727 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/support/GroupRateLimiter.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/support/GroupRateLimiter.java @@ -69,7 +69,7 @@ public class GroupRateLimiter implements InitializingBean { public void acquire() { double seconds = rateLimiter.acquire(); - if (seconds > 1) + if (seconds > groupProps.getTpsTooLowWarnWaitSeconds()) notification.send("{} wait too long to acquire rate limiter: {} seconds", name, seconds); }