Public connection status, tests

Author: grzegorzswistak

src/main/java/com/orange/lo/sdk/mqtt/AbstractDataManagementMqtt.java

@@ -66,7 +66,7 @@ public void connect() {
         }
     }
 
-    private boolean isConnected() {
+    public boolean isConnected() {
         return mqttClient.isConnected();
     }
 

src/test/java/com/orange/lo/sdk/externalconnector/DataManagementExtConnectorTest.java

@@ -201,6 +201,17 @@ void shouldSendMessageToChangedDataTopicTemplateAsSelectedNodeIdWhenDataTopicTem
         verify(mqttClient, times(1)).publish(eq(expectedTopic), hasSamePayload(expectedMessage));
     }
 
+    @Test
+    void shouldCallMqttClientWhenIsCheckingConnectionStatus() {
+        parameters = LOApiClientParameters.builder()
+                .apiKey(API_KEY)
+                .build();
+        this.dataManagementExtConnector = new DataManagementExtConnector(parameters, () -> mqttClient);
+        dataManagementExtConnector.isConnected();
+
+        verify(mqttClient, times(1)).isConnected();
+    }
+
     private NodeStatus getNodeStatus() {
         NodeStatus nodeStatus = new NodeStatus();
         nodeStatus.setStatus(Status.ONLINE);

src/test/java/com/orange/lo/sdk/fifomqtt/DataManagementFifoTest.java

@@ -50,4 +50,11 @@ void shouldCallMqttClientWhenSubscribe() throws MqttException {
         verify(mqttClient, times(1)).connect(any(MqttConnectOptions.class));
         verify(mqttClient, times(1)).subscribe(any(String[].class), any(int[].class), any(IMqttMessageListener[].class));
     }
+
+    @Test
+    void shouldCallMqttClientWhenIsCheckingConnectionStatus() {
+        dataManagementFifo.isConnected();
+
+        verify(mqttClient, times(1)).isConnected();
+    }
 }