summaryrefslogtreecommitdiffstats
path: root/plugins
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@ifm.com>2022-05-06 20:21:25 +0200
committerMatthias Beyer <matthias.beyer@ifm.com>2022-05-10 15:04:55 +0200
commit9f6050f8b2922ae2e2daebd156c451956049c257 (patch)
treec3b1b3eeff8c35720d44a4ce30e3d16b4332c426 /plugins
parent69d08d17ac9f9e796cc7c43c129250ff9e10b7d0 (diff)
plugin_measurement_filter: Adapt to Plugin::handle_message() interface change
In commit abab64c856c0c299b13fcc1857a5b78f449e4a9e ("Add AnyMessage & AnyMessages") The `ReplySender` was renamed to `ReplySenderFor` and its interface was changed so that we can specify the plugin_measurement_filter message type of the original instead of the message type of the reply. This commit adapts the plugin_measurement_filter implementation for this change. Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
Diffstat (limited to 'plugins')
-rw-r--r--plugins/plugin_measurement_filter/src/plugin.rs5
1 files changed, 2 insertions, 3 deletions
diff --git a/plugins/plugin_measurement_filter/src/plugin.rs b/plugins/plugin_measurement_filter/src/plugin.rs
index 4ea951e3..dedb0880 100644
--- a/plugins/plugin_measurement_filter/src/plugin.rs
+++ b/plugins/plugin_measurement_filter/src/plugin.rs
@@ -2,10 +2,9 @@ use async_trait::async_trait;
use tracing::debug;
use tedge_api::address::Address;
-use tedge_api::address::ReplySender;
+use tedge_api::address::ReplySenderFor;
use tedge_api::error::PluginError;
use tedge_api::plugin::Handle;
-use tedge_api::plugin::Message;
use tedge_api::plugin::Plugin;
use tedge_lib::measurement::Measurement;
use tracing::trace;
@@ -60,7 +59,7 @@ impl Handle<Measurement> for MeasurementFilterPlugin {
async fn handle_message(
&self,
message: Measurement,
- _sender: ReplySender<<Measurement as Message>::Reply>,
+ _sender: ReplySenderFor<Measurement>,
) -> Result<(), PluginError> {
trace!("Extracting with {:?} from {:?}", self.extractor, message);
if let Some(value) = message.extract(&self.extractor.0) {