From 54db1f3b063cb52ccff2448f0b5e48aacb85c96b Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Wed, 6 Jul 2022 10:05:57 +0800 Subject: [PATCH] =?UTF-8?q?=20=E8=A7=A6=E5=8F=91=E9=99=90=E9=A2=91?= =?UTF-8?q?=E5=90=8E=E5=A4=9A=E8=B0=83=E7=94=A8=E4=BA=86=E4=B8=80=E6=AC=A1?= =?UTF-8?q?callback=EF=BC=8C=E5=8E=BB=E6=8E=89=E6=97=A0=E7=94=A8=E7=9A=84?= =?UTF-8?q?=E8=B0=83=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- broker/src/main/java/io/moquette/imhandler/IMHandler.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/broker/src/main/java/io/moquette/imhandler/IMHandler.java b/broker/src/main/java/io/moquette/imhandler/IMHandler.java index 2c8edba9..f06eba08 100755 --- a/broker/src/main/java/io/moquette/imhandler/IMHandler.java +++ b/broker/src/main/java/io/moquette/imhandler/IMHandler.java @@ -166,14 +166,6 @@ abstract public class IMHandler { public ErrorCode preAction(String clientID, String fromUser, String topic, Qos1PublishHandler.IMCallback callback, ProtoConstants.RequestSourceType requestSourceType) { LOG.info("imHandler fromUser={}, clientId={}, topic={}", fromUser, clientID, topic); if(requestSourceType == ProtoConstants.RequestSourceType.Request_From_User && !mLimitCounter.isGranted(clientID + fromUser + topic)) { - ByteBuf ackPayload = Unpooled.buffer(); - ackPayload.ensureWritable(1).writeByte(ERROR_CODE_OVER_FREQUENCY.getCode()); - try { - callback.onIMHandled(ERROR_CODE_OVER_FREQUENCY, ackPayload); - } catch (Exception e) { - e.printStackTrace(); - Utility.printExecption(LOG, e); - } return ErrorCode.ERROR_CODE_OVER_FREQUENCY; } return ErrorCode.ERROR_CODE_SUCCESS;