From 19b7bc42efad1256acfe78552f16b9bef505e333 Mon Sep 17 00:00:00 2001 From: imhao183 Date: Wed, 11 Nov 2020 18:34:43 +0800 Subject: [PATCH] fix build error --- broker/src/main/java/io/moquette/imhandler/IMHandler.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/broker/src/main/java/io/moquette/imhandler/IMHandler.java b/broker/src/main/java/io/moquette/imhandler/IMHandler.java index d695149f..359b396f 100755 --- a/broker/src/main/java/io/moquette/imhandler/IMHandler.java +++ b/broker/src/main/java/io/moquette/imhandler/IMHandler.java @@ -34,10 +34,7 @@ import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; -import java.util.Collection; -import java.util.HashSet; -import java.util.LinkedHashSet; -import java.util.Set; +import java.util.*; import static cn.wildfirechat.common.ErrorCode.ERROR_CODE_OVER_FREQUENCY; import static cn.wildfirechat.common.ErrorCode.ERROR_CODE_SUCCESS; @@ -273,7 +270,7 @@ abstract public class IMHandler { Set notifyReceivers = new HashSet<>(receivers); LOG.info("Multicast recall receiver count: {}", notifyReceivers.size()); - mServer.getImBusinessScheduler().execute(() -> publisher.publish2Receivers(updatedMessage, notifyReceivers, null, ProtoConstants.PullType.Pull_Normal, false)); + mServer.getImBusinessScheduler().execute(() -> publisher.publish2Receivers(updatedMessage, notifyReceivers, null, ProtoConstants.PullType.Pull_Normal)); return notifyReceivers.size(); }