Add connect check size

hivemq · Oct 2, 2023 · bd43018 · bd43018
1 parent e32860e
commit bd43018
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/src/main/java/com/hivemq/bootstrap/netty/ChannelDependencies.java b/src/main/java/com/hivemq/bootstrap/netty/ChannelDependencies.java
@@ -100,7 +100,9 @@ public ChannelDependencies(
             final @NotNull ExceptionHandler exceptionHandler,
             final @NotNull PingRequestHandler pingRequestHandler,
             final @NotNull RestrictionsConfigurationService restrictionsConfigurationService,
-            final @NotNull MqttConnectDecoder mqttConnectDecoder, final MqttConnacker mqttConnacker, final @NotNull EventLog eventLog,
+            final @NotNull MqttConnectDecoder mqttConnectDecoder,
+            final @NotNull MqttConnacker mqttConnacker,
+            final @NotNull EventLog eventLog,
             final @NotNull SslParameterHandler sslParameterHandler,
             final @NotNull MqttDecoders mqttDecoders,
             final @NotNull EncoderFactory encoderFactory,

diff --git a/src/test/java/com/hivemq/bootstrap/netty/ChannelDependenciesTest.java b/src/test/java/com/hivemq/bootstrap/netty/ChannelDependenciesTest.java
@@ -32,6 +32,7 @@
 import com.hivemq.mqtt.handler.InterceptorHandler;
 import com.hivemq.mqtt.handler.auth.AuthHandler;
 import com.hivemq.mqtt.handler.auth.AuthInProgressMessageHandler;
+import com.hivemq.mqtt.handler.connack.MqttConnacker;
 import com.hivemq.mqtt.handler.connect.ConnectHandler;
 import com.hivemq.mqtt.handler.connect.ConnectionLimiterHandler;
 import com.hivemq.mqtt.handler.connect.NoConnectIdleHandler;
@@ -92,6 +93,9 @@ public class ChannelDependenciesTest {
     @Mock
     private @NotNull MqttConnectDecoder mqttConnectDecoder;
 
+    @Mock
+    private @NotNull MqttConnacker mqttConnacker;
+
     @Mock
     private @NotNull EncoderFactory encoderFactory;
 
@@ -159,7 +163,9 @@ public void setUp() throws Exception {
                 exceptionHandler,
                 pingRequestHandler,
                 restrictionsConfigurationService,
-                mqttConnectDecoder, mqttConnacker, eventLog,
+                mqttConnectDecoder,
+                mqttConnacker,
+                eventLog,
                 sslParameterHandler,
                 mqttDecoders,
                 encoderFactory,