|
|
|
@ -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<MqttPublishMessage> 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)); |
|
|
|
|