Adding Callback on MQTTConnect

Cumulocity-IoT · Mar 15, 2024 · 09c28e2 · 09c28e2
1 parent 8dfb51e
commit 09c28e2
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/dynamic-mapping-service/src/main/java/dynamic/mapping/connector/mqtt/MQTTClient.java b/dynamic-mapping-service/src/main/java/dynamic/mapping/connector/mqtt/MQTTClient.java
@@ -230,9 +230,6 @@ tenant, isConnected(),
                     }
                 }
                 try {
-
-                    mqttCallback = new MQTTCallback(dispatcher, tenant, MQTTClient.getConnectorType());
-
                     boolean useTLS = (Boolean) connectorConfiguration.getProperties().getOrDefault("useTLS", false);
                     boolean useSelfSignedCertificate = (Boolean) connectorConfiguration.getProperties()
                             .getOrDefault("useSelfSignedCertificate", false);
@@ -283,13 +280,14 @@ tenant, isConnected(),
                                 // .maxDelay(10000, TimeUnit.MILLISECONDS).build())
                                 .buildBlocking();
                     }
+                    //Registering Callback
+                    Mqtt3AsyncClient mqtt3AsyncClient = mqttClient.toAsync();
+                    mqtt3AsyncClient.publishes(MqttGlobalPublishFilter.ALL, mqttCallback);
 
-                    // mqttClient.setCallaBack(mqttCallback);
                     // MqttConnectOptions connOpts = new MqttConnectOptions();
                     // connOpts.setCleanSession(true);
                     // connOpts.setAutomaticReconnect(false);
                     // log.info("Tenant {} - DANGEROUS-LOG password: {}", tenant, password);
-
                     Mqtt3ConnAck ack = mqttClient.connect();
                     if (!ack.getReturnCode().equals(Mqtt3ConnAckReturnCode.SUCCESS)) {
                         throw new ConnectorException("Tenant " + tenant + " - Error connecting to broker:"