From 49fcc73f7884bbe76aeb86f93a489e21ae6f3844 Mon Sep 17 00:00:00 2001 From: imhao183 Date: Fri, 23 Apr 2021 09:51:42 +0800 Subject: [PATCH] =?UTF-8?q?server=20api/robot=20api/channel=20api=E4=B8=8D?= =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E5=AE=A2=E6=88=B7=E7=AB=AF=E9=99=90=E5=88=B6?= =?UTF-8?q?=E9=A2=91=E7=8E=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java b/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java index 75aeccfd..2ee2def6 100755 --- a/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java +++ b/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java @@ -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 {