♻️ [Test] Added autoreconnect of Kura Device

Signed-off-by: Alberto Codutti <[email protected]>
eclipse-kapua · Jan 21, 2025 · 7af3921 · 7af3921
1 parent 4e05b8e
commit 7af3921
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/.../test-steps/src/main/java/org/eclipse/kapua/service/device/registry/steps/KuraDevice.java b/.../test-steps/src/main/java/org/eclipse/kapua/service/device/registry/steps/KuraDevice.java
@@ -249,10 +249,12 @@ public void mqttClientConnect() {
         MqttConnectOptions clientOpts = new MqttConnectOptions();
         clientOpts.setUserName(CLIENT_USER);
         clientOpts.setPassword(CLIENT_PASSWORD.toCharArray());
+        clientOpts.setAutomaticReconnect(true);
 
         MqttConnectOptions serverOpts = new MqttConnectOptions();
         serverOpts.setUserName(SERVER_USER);
         serverOpts.setPassword(SERVER_PASSWORD.toCharArray());
+        serverOpts.setAutomaticReconnect(true);
 
         try {
             mqttClient.connect(clientOpts);