diff options
| author | Rina Fujino <18257209+rina23q@users.noreply.github.com> | 2022-02-08 19:18:17 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-08 19:18:17 +0100 |
| commit | ea0a0b58333ee22a71955db499366e1858d12e42 (patch) | |
| tree | 3abc205c76ad0fab03c6ec8ddfe5f1331de4ed37 /crates/core/tedge_mapper | |
| parent | 9cfb634c8bceb63b05fa2c1362a0ebdda9cef439 (diff) | |
| parent | 86e8b8079bc1c8e4b75f46becb27c31d95284f0c (diff) | |
Merge pull request #838 from rina23q/hotfix/wrong-topic-name-in-c8y-converter
Fix tedge/measurement to tedge/measurements
Diffstat (limited to 'crates/core/tedge_mapper')
| -rw-r--r-- | crates/core/tedge_mapper/src/c8y_converter.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/crates/core/tedge_mapper/src/c8y_converter.rs b/crates/core/tedge_mapper/src/c8y_converter.rs index ccc8a975..475bac40 100644 --- a/crates/core/tedge_mapper/src/c8y_converter.rs +++ b/crates/core/tedge_mapper/src/c8y_converter.rs @@ -21,6 +21,7 @@ const SUPPORTED_OPERATIONS_DIRECTORY: &str = "/etc/tedge/operations"; const SMARTREST_PUBLISH_TOPIC: &str = "c8y/s/us"; const TEDGE_ALARMS_TOPIC: &str = "tedge/alarms/"; const INTERNAL_ALARMS_TOPIC: &str = "c8y-internal/alarms/"; +const TEDGE_MEASUREMENTS_TOPIC: &str = "tedge/measurements"; pub struct CumulocityConverter { pub(crate) size_threshold: SizeThreshold, @@ -110,7 +111,8 @@ impl Converter for CumulocityConverter { fn try_convert(&mut self, input: &Message) -> Result<Vec<Message>, ConversionError> { let () = self.size_threshold.validate(input.payload_str()?)?; - if input.topic.name.starts_with("tedge/measurement") { + + if input.topic.name.starts_with(TEDGE_MEASUREMENTS_TOPIC) { self.try_convert_measurement(input) } else if input.topic.name.starts_with(TEDGE_ALARMS_TOPIC) { self.alarm_converter.try_convert_alarm(input) |