From 236e6448beb8983bc3d92509bd9e433622782d50 Mon Sep 17 00:00:00 2001 From: Andrii Shvaika Date: Thu, 13 Jan 2022 16:59:29 +0200 Subject: [PATCH] Fix unit tests logic --- .../server/transport/mqtt/MqttTransportHandlerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/common/transport/mqtt/src/test/java/org/thingsboard/server/transport/mqtt/MqttTransportHandlerTest.java b/common/transport/mqtt/src/test/java/org/thingsboard/server/transport/mqtt/MqttTransportHandlerTest.java index a9903fe867..cc26ff6fa8 100644 --- a/common/transport/mqtt/src/test/java/org/thingsboard/server/transport/mqtt/MqttTransportHandlerTest.java +++ b/common/transport/mqtt/src/test/java/org/thingsboard/server/transport/mqtt/MqttTransportHandlerTest.java @@ -116,7 +116,7 @@ public class MqttTransportHandlerTest { MqttConnectMessage msg = getMqttConnectMessage(); willDoNothing().given(handler).processConnect(ctx, msg); - handler.processMqttMsg(ctx, msg); + handler.channelRead(ctx, msg); assertThat(handler.address, is(IP_ADDR)); assertThat(handler.deviceSessionCtx.getChannel(), is(ctx)); @@ -152,7 +152,7 @@ public class MqttTransportHandlerTest { List messages = Stream.generate(this::getMqttPublishMessage).limit(MSG_QUEUE_LIMIT).collect(Collectors.toList()); - messages.forEach((msg) -> handler.processMqttMsg(ctx, msg)); + messages.forEach((msg) -> handler.channelRead(ctx, msg)); assertThat(handler.address, is(IP_ADDR)); assertThat(handler.deviceSessionCtx.getChannel(), is(ctx));