[broker-23] fix build according dependency changes

Author: crazyrokr

src/main/java/com/ss/mqtt/broker/network/MqttConnection.java

@@ -1,19 +1,17 @@
 package com.ss.mqtt.broker.network;
 
 import com.ss.mqtt.broker.config.MqttConnectionConfig;
+import com.ss.mqtt.broker.handler.packet.in.PacketInHandler;
 import com.ss.mqtt.broker.model.MqttSession;
 import com.ss.mqtt.broker.model.MqttVersion;
-import com.ss.mqtt.broker.network.client.MqttClient;
 import com.ss.mqtt.broker.network.client.MqttClient.UnsafeMqttClient;
 import com.ss.mqtt.broker.network.packet.MqttPacketReader;
 import com.ss.mqtt.broker.network.packet.MqttPacketWriter;
 import com.ss.mqtt.broker.network.packet.in.MqttReadablePacket;
-import com.ss.mqtt.broker.handler.packet.in.PacketInHandler;
 import com.ss.mqtt.broker.network.packet.out.MqttWritablePacket;
 import com.ss.rlib.network.BufferAllocator;
 import com.ss.rlib.network.Connection;
 import com.ss.rlib.network.Network;
-import com.ss.rlib.network.NetworkCryptor;
 import com.ss.rlib.network.impl.AbstractConnection;
 import com.ss.rlib.network.packet.PacketReader;
 import com.ss.rlib.network.packet.PacketWriter;
@@ -53,7 +51,7 @@ public MqttConnection(
         @NotNull MqttConnectionConfig config,
         @NotNull Function<MqttConnection, UnsafeMqttClient> clientFactory
     ) {
-        super(network, channel, NetworkCryptor.NULL, bufferAllocator, maxPacketsByRead);
+        super(network, channel, bufferAllocator, maxPacketsByRead);
         this.packetHandlers = packetHandlers;
         this.config = config;
         this.mqttVersion = MqttVersion.MQTT_3_1_1;
@@ -72,7 +70,7 @@ public boolean isSupported(@NotNull MqttVersion mqttVersion) {
             channel,
             bufferAllocator,
             this::updateLastActivity,
-            this::handleReadPacket,
+            this::handleReceivedPacket,
             maxPacketsByRead
         );
     }

src/main/java/com/ss/mqtt/broker/network/packet/MqttPacketReader.java

@@ -4,6 +4,7 @@
 import com.ss.mqtt.broker.network.packet.in.*;
 import com.ss.mqtt.broker.util.MqttDataUtils;
 import com.ss.rlib.common.function.ByteFunction;
+import com.ss.rlib.common.function.NotNullConsumer;
 import com.ss.rlib.common.util.NumberUtils;
 import com.ss.rlib.common.util.array.ArrayFactory;
 import com.ss.rlib.network.BufferAllocator;
@@ -13,7 +14,6 @@
 
 import java.nio.ByteBuffer;
 import java.nio.channels.AsynchronousSocketChannel;
-import java.util.function.Consumer;
 
 public class MqttPacketReader extends AbstractPacketReader<MqttReadablePacket, MqttConnection> {
 
@@ -43,7 +43,7 @@ public MqttPacketReader(
         @NotNull AsynchronousSocketChannel channel,
         @NotNull BufferAllocator bufferAllocator,
         @NotNull Runnable updateActivityFunction,
-        @NotNull Consumer<MqttReadablePacket> readPacketHandler,
+        @NotNull NotNullConsumer<MqttReadablePacket> readPacketHandler,
         int maxPacketsByRead
     ) {
         super(

src/main/java/com/ss/mqtt/broker/network/packet/MqttPacketWriter.java

@@ -3,6 +3,9 @@
 import com.ss.mqtt.broker.network.MqttConnection;
 import com.ss.mqtt.broker.network.packet.out.MqttWritablePacket;
 import com.ss.mqtt.broker.util.MqttDataUtils;
+import com.ss.rlib.common.function.NotNullBiConsumer;
+import com.ss.rlib.common.function.NotNullConsumer;
+import com.ss.rlib.common.function.NullableSupplier;
 import com.ss.rlib.network.BufferAllocator;
 import com.ss.rlib.network.packet.WritablePacket;
 import com.ss.rlib.network.packet.impl.AbstractPacketWriter;
@@ -21,9 +24,9 @@ public MqttPacketWriter(
         @NotNull AsynchronousSocketChannel channel,
         @NotNull BufferAllocator bufferAllocator,
         @NotNull Runnable updateActivityFunction,
-        @NotNull Supplier<@NotNull WritablePacket> nextWritePacketSupplier,
-        @NotNull Consumer<@NotNull WritablePacket> writtenPacketHandler,
-        @NotNull BiConsumer<@NotNull WritablePacket, Boolean> sentPacketHandler
+        @NotNull NullableSupplier<@NotNull WritablePacket> nextWritePacketSupplier,
+        @NotNull NotNullConsumer<@NotNull WritablePacket> writtenPacketHandler,
+        @NotNull NotNullBiConsumer<@NotNull WritablePacket, Boolean> sentPacketHandler
     ) {
         super(
             connection,