server api/robot api/channel api不进行客户端限制频率

2021-04-23 09:51:42 +08:00
parent d491ac0ad7
commit 49fcc73f78
1 changed files with 1 additions and 1 deletions
@@ -148,7 +148,7 @@ public class Qos1PublishHandler extends QosPublishHandler {

 	void imHandler(String clientID, String fromUser, String topic, byte[] payloadContent, IMCallback callback, boolean isAdmin, boolean isRobotOrChannel) {
        LOG.info("imHandler fromUser={}, topic={}", fromUser, topic);
-        if(!mLimitCounter.isGranted(clientID + fromUser + topic)) {
+        if(!isAdmin && !isRobotOrChannel && !mLimitCounter.isGranted(clientID + fromUser + topic)) {
            ByteBuf ackPayload = Unpooled.buffer();
            ackPayload.ensureWritable(1).writeByte(ERROR_CODE_OVER_FREQUENCY.getCode());
            try {