diff options
author | Matthias Beyer <matthias.beyer@ifm.com> | 2022-05-06 20:21:25 +0200 |
---|---|---|
committer | Matthias Beyer <matthias.beyer@ifm.com> | 2022-05-10 15:04:55 +0200 |
commit | 9f6050f8b2922ae2e2daebd156c451956049c257 (patch) | |
tree | c3b1b3eeff8c35720d44a4ce30e3d16b4332c426 /plugins | |
parent | 69d08d17ac9f9e796cc7c43c129250ff9e10b7d0 (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.rs | 5 |
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) { |