dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MqttTransportHandler fixed test

Browse Source
This commit is contained in:
Sergey Matvienko 2022-01-10 18:41:53 +02:00
parent 0ef9d5753c
commit ef53df7512
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
common/transport/mqtt/src/test/java/org/thingsboard/server/transport/mqtt/MqttTransportHandlerTest.java
View File

@ -23,7 +23,6 @@ import io.netty.handler.codec.mqtt.MqttConnectMessage;
import io.netty.handler.codec.mqtt.MqttConnectPayload; import io.netty.handler.codec.mqtt.MqttConnectPayload;
import io.netty.handler.codec.mqtt.MqttConnectVariableHeader; import io.netty.handler.codec.mqtt.MqttConnectVariableHeader;
import io.netty.handler.codec.mqtt.MqttFixedHeader; import io.netty.handler.codec.mqtt.MqttFixedHeader;
import io.netty.handler.codec.mqtt.MqttMessage;
import io.netty.handler.codec.mqtt.MqttMessageType; import io.netty.handler.codec.mqtt.MqttMessageType;
import io.netty.handler.codec.mqtt.MqttPublishMessage; import io.netty.handler.codec.mqtt.MqttPublishMessage;
import io.netty.handler.codec.mqtt.MqttPublishVariableHeader; import io.netty.handler.codec.mqtt.MqttPublishVariableHeader;
@ -118,7 +117,8 @@ public class MqttTransportHandlerTest {
handler.processMqttMsg(ctx, msg); handler.processMqttMsg(ctx, msg);
assertThat(handler.address, is(IP_ADDR)); assertThat(handler.ip, is(handler.getIpv4(IP_ADDR)));
assertThat(handler.port, is(IP_ADDR.getPort()));
assertThat(handler.deviceSessionCtx.getChannel(), is(ctx)); assertThat(handler.deviceSessionCtx.getChannel(), is(ctx));
verify(handler, never()).doDisconnect(); verify(handler, never()).doDisconnect();
verify(handler, times(1)).processConnect(ctx, msg); verify(handler, times(1)).processConnect(ctx, msg);
@ -154,7 +154,7 @@ public class MqttTransportHandlerTest {
messages.forEach((msg) -> handler.processMqttMsg(ctx, msg)); messages.forEach((msg) -> handler.processMqttMsg(ctx, msg));
assertThat(handler.address, is(IP_ADDR)); assertThat(handler.ip, is(handler.getIpv4(IP_ADDR)));
assertThat(handler.deviceSessionCtx.getChannel(), is(ctx)); assertThat(handler.deviceSessionCtx.getChannel(), is(ctx));
assertThat(handler.deviceSessionCtx.isConnected(), is(false)); assertThat(handler.deviceSessionCtx.isConnected(), is(false));
assertThat(handler.deviceSessionCtx.getMsgQueueSize(), is(MSG_QUEUE_LIMIT)); assertThat(handler.deviceSessionCtx.getMsgQueueSize(), is(MSG_QUEUE_LIMIT));