Browse Source

removed getMqttConfig method

pull/10958/head
IrynaMatveieva 2 years ago
parent
commit
80a53a840c
  1. 4
      rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/mqtt/azure/TbAzureIotHubNode.java
  2. 4
      rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/mqtt/azure/TbAzureIotHubNodeTest.java

4
rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/mqtt/azure/TbAzureIotHubNode.java

@ -74,10 +74,6 @@ public class TbAzureIotHubNode extends TbMqttNode {
} }
} }
TbMqttNodeConfiguration getMqttNodeConfiguration() {
return this.mqttNodeConfiguration;
}
MqttClient initAzureClient(TbContext ctx) throws Exception { MqttClient initAzureClient(TbContext ctx) throws Exception {
return initClient(ctx); return initClient(ctx);
} }

4
rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/mqtt/azure/TbAzureIotHubNodeTest.java

@ -21,6 +21,7 @@ import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock; import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoExtension;
import org.springframework.test.util.ReflectionTestUtils;
import org.thingsboard.common.util.AzureIotHubUtil; import org.thingsboard.common.util.AzureIotHubUtil;
import org.thingsboard.common.util.JacksonUtil; import org.thingsboard.common.util.JacksonUtil;
import org.thingsboard.mqtt.MqttClient; import org.thingsboard.mqtt.MqttClient;
@ -98,7 +99,8 @@ public class TbAzureIotHubNodeTest {
assertThatNoException().isThrownBy( assertThatNoException().isThrownBy(
() -> azureIotHubNode.init(ctxMock, new TbNodeConfiguration(JacksonUtil.valueToTree(azureIotHubNodeConfig)))); () -> azureIotHubNode.init(ctxMock, new TbNodeConfiguration(JacksonUtil.valueToTree(azureIotHubNodeConfig))));
TbMqttNodeConfiguration mqttNodeConfiguration = azureIotHubNode.getMqttNodeConfiguration(); var mqttNodeConfiguration = (TbMqttNodeConfiguration) ReflectionTestUtils.getField(azureIotHubNode, "mqttNodeConfiguration");
assertThat(mqttNodeConfiguration).isNotNull();
assertThat(mqttNodeConfiguration.getPort()).isEqualTo(8883); assertThat(mqttNodeConfiguration.getPort()).isEqualTo(8883);
assertThat(mqttNodeConfiguration.isCleanSession()).isTrue(); assertThat(mqttNodeConfiguration.isCleanSession()).isTrue();
} }

Loading…
Cancel
Save