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

Revert "MqttTransportHandler fixed test"

Browse Source 
This reverts commit ef53df75128a0502c5727d4229acd37cd79c1aaa.
This commit is contained in:
Sergey Matvienko 2022-01-14 11:50:31 +02:00
parent 217a84f1f2
commit 565b6284d2
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,6 +23,7 @@ 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;
@ -117,8 +118,7 @@ public class MqttTransportHandlerTest {
handler.processMqttMsg(ctx, msg); handler.processMqttMsg(ctx, msg);
assertThat(handler.ip, is(handler.getIpv4(IP_ADDR))); assertThat(handler.address, is(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.ip, is(handler.getIpv4(IP_ADDR))); assertThat(handler.address, is(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));