File tree Expand file tree Collapse file tree 1 file changed +9
-4
lines changed
crates/extensions/tedge_mqtt_bridge/src Expand file tree Collapse file tree 1 file changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -340,21 +340,26 @@ impl<'a> BridgeHealth<'a> {
340
340
last_err : Some ( "dummy error" . into ( ) ) ,
341
341
}
342
342
}
343
+
343
344
async fn update (
344
345
& mut self ,
345
346
result : & NotificationRes ,
346
347
companion_bridge_half : & mut BidirectionalChannelHalf < Option < Publish > > ,
347
348
) {
348
349
let name = self . name ;
349
350
let ( err, health_payload) = match result {
350
- Ok ( _) => ( None , MQTT_BRIDGE_UP_PAYLOAD ) ,
351
+ Ok ( event) => {
352
+ if let Event :: Incoming ( Incoming :: ConnAck ( _) ) = event {
353
+ info ! ( "MQTT bridge connected to {name} broker" )
354
+ }
355
+ ( None , MQTT_BRIDGE_UP_PAYLOAD )
356
+ }
351
357
Err ( err) => ( Some ( err. to_string ( ) ) , MQTT_BRIDGE_DOWN_PAYLOAD ) ,
352
358
} ;
353
359
354
360
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}" ) ,
361
+ if let Some ( err) = & err {
362
+ error ! ( "MQTT bridge failed to connect to {name} broker: {err}" )
358
363
}
359
364
self . last_err = err;
360
365
You can’t perform that action at this time.
0 commit comments