diff options
author | Matthias Beyer <matthias.beyer@ifm.com> | 2022-04-19 14:22:33 +0200 |
---|---|---|
committer | Matthias Beyer <matthias.beyer@ifm.com> | 2022-04-20 12:02:08 +0200 |
commit | c49a2c3fa5b2c2aafe1d1fb27295803af2e3c0f6 (patch) | |
tree | 757eee254e96d736a6cd7975a31981e3b4b821df | |
parent | b6188ab724026df03983811307ccdaa6cc49d1e0 (diff) |
Fix: Make sure error is reported
Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
-rw-r--r-- | plugins/plugin_mqtt_measurement_bridge/src/lib.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/plugins/plugin_mqtt_measurement_bridge/src/lib.rs b/plugins/plugin_mqtt_measurement_bridge/src/lib.rs index 9acac73b..bd35cdda 100644 --- a/plugins/plugin_mqtt_measurement_bridge/src/lib.rs +++ b/plugins/plugin_mqtt_measurement_bridge/src/lib.rs @@ -114,7 +114,10 @@ impl Handle<tedge_lib::measurement::Measurement> for MqttMeasurementBridgePlugin let outgoing = plugin_mqtt::OutgoingMessage::for_payload(&message, self.topic.clone())?; match self.mqtt_plugin_addr.send(outgoing).await { Ok(_) => trace!("Message forwarded to MQTT plugin"), - Err(_) => trace!("Message not send"), + Err(_) => { + trace!("Message not send"); + return Err(miette::miette!("Failed to send message")) + }, } Ok(()) } |