summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@ifm.com>2022-04-19 14:22:33 +0200
committerMatthias Beyer <matthias.beyer@ifm.com>2022-04-20 12:02:08 +0200
commitc49a2c3fa5b2c2aafe1d1fb27295803af2e3c0f6 (patch)
tree757eee254e96d736a6cd7975a31981e3b4b821df
parentb6188ab724026df03983811307ccdaa6cc49d1e0 (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.rs5
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(())
}