removes code to reconnect

icaroerasmo · Oct 21, 2024 · fa27fa5 · fa27fa5
1 parent 58bbc22
commit fa27fa5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 49 deletions.
diff --git a/src/main/java/com/icaroerasmo/config/DtTMqttCallBack.java b/src/main/java/com/icaroerasmo/config/DtTMqttCallBack.java
diff --git a/src/main/java/com/icaroerasmo/config/MqttConfig.java b/src/main/java/com/icaroerasmo/config/MqttConfig.java
@@ -57,15 +57,9 @@ public IMqttClient mqttClient() throws MqttException {
     }
 
     @Bean
-    @DependsOn({"mqttClient", "registerListeners"})
+    @DependsOn({"registerListeners"})
     public Void listen(IMqttClient mqttClient, List<AbstractListener> listeners) {
-
-        DtTMqttCallBack callBack = new DtTMqttCallBack(mqttClient,
-                listeners.stream().map(AbstractListener::getTopic).toList());
-
-        listeners.forEach(listener -> listener.listen());
-        mqttClient.setCallback(callBack);
-
+        listeners.forEach(AbstractListener::listen);
         return null;
     }