Skip to content

Commit 30e2434

Browse files
committed
Only log error when message changes
Signed-off-by: James Rhodes <jarhodes314@gmail.com>
1 parent a6db6bc commit 30e2434

File tree

1 file changed

+7
-8
lines changed
  • crates/extensions/tedge_mqtt_bridge/src

1 file changed

+7
-8
lines changed

crates/extensions/tedge_mqtt_bridge/src/lib.rs

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -347,18 +347,17 @@ impl<'a> BridgeHealth<'a> {
347347
) {
348348
let name = self.name;
349349
let (err, health_payload) = match result {
350-
Ok(_) => {
351-
info!("MQTT bridge connected to {name} broker");
352-
(None, MQTT_BRIDGE_UP_PAYLOAD)
353-
}
354-
Err(err) => {
355-
error!("MQTT bridge failed to connect to {name} broker: {err}");
356-
(Some(err.to_string()), MQTT_BRIDGE_DOWN_PAYLOAD)
357-
}
350+
Ok(_) => (None, MQTT_BRIDGE_UP_PAYLOAD),
351+
Err(err) => (Some(err.to_string()), MQTT_BRIDGE_DOWN_PAYLOAD),
358352
};
359353

360354
if self.last_err != err {
355+
match &err {
356+
None => info!("MQTT bridge connected to {name} broker"),
357+
Some(err) => error!("MQTT bridge failed to connect to {name} broker: {err}"),
358+
}
361359
self.last_err = err;
360+
362361
if let Some(health_topic) = &self.health_topic {
363362
self.target
364363
.publish(health_topic, QoS::AtLeastOnce, true, health_payload)

0 commit comments

Comments
 (0)