|
|
|
@ -276,7 +276,7 @@ public class FrontendMessagePushService implements MqttCallback { |
|
|
|
*/ |
|
|
|
private void publishJson(String topic, Object data) { |
|
|
|
String json = JacksonMapper.getInstance().toJson(data); |
|
|
|
log.info("Publishing to topic: {}, data: {}", topic, json); |
|
|
|
// log.info("Publishing to topic: {}, data: {}", topic, json);
|
|
|
|
publish(topic, json); |
|
|
|
} |
|
|
|
|
|
|
|
@ -296,7 +296,7 @@ public class FrontendMessagePushService implements MqttCallback { |
|
|
|
|
|
|
|
mqttClient.publish(topic, message); |
|
|
|
|
|
|
|
log.debug("Published to {}: {}", topic, payload); |
|
|
|
log.info("Published to [{}] {}", topic, payload); |
|
|
|
} catch (MqttException e) { |
|
|
|
log.error("Failed to publish to topic: " + topic, e); |
|
|
|
} |
|
|
|
|