diff options
| author | Didier Wenzek <didier.wenzek@acidalie.com> | 2022-01-19 15:21:04 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-01-19 15:21:04 +0000 |
| commit | 7b559af54b5413f987b1a9bd9747ad6393c095da (patch) | |
| tree | b390280494af330af7f41ca10af52781b395ac28 /crates/core/tedge_mapper/src/c8y_converter.rs | |
| parent | 0f38421fb78058552e8b477f431abfc24c61e48b (diff) | |
Refactoring the MQTT client API (#575)
* Basic data types for MQTT channels
* Mqtt connection
* Mqtt-channel: subscribe to topics
* Mqtt-channel: publish messages
Signed-off-by: Wenzek <diw@softwareag.com>
* Mqtt-channel: an MQTT client as no direct dependency to MQTT
Signed-off-by: Wenzek <diw@softwareag.com>
* Mqtt-chanels: no message lost on reconnect
Signed-off-by: Wenzek <diw@softwareag.com>
* Cargo fmt
Signed-off-by: Wenzek <diw@softwareag.com>
* Merge with child device management
* Remove the dependency to the `async-broadcast` and `async-channel` crates
* Moving the helper functions to the `mqtt_tests` crate
* Ensure an MQTT client can be tested without an MQTT broker
* Removing dependency on the mqtt_client crate
* Use the new `mqtt_channel` crate in the `sm-c8y` mapper
This actually fixes the bug #570
* [570] Cargo fmt
* Remove the dependency of the collectd mapper on the `mqtt_client` crate
Signed-off-by: Wenzek <diw@softwareag.com>
* Make configurable the maximum size of a message
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Fix typo in comment
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Use mqtt_channel instead of mqtt_client in tedge_agent
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Improve doc comments
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Add error case on closed channel
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Add PubChannel & SubChannel traits
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Cargo fmt
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Revert erroneously added changes
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Add a channel for errors
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Log MQTT connection errors
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Fix HTTP_proxy port
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Remove unused code
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Improve tests
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Move session configuration from Connection to Config
* Set max_packet_size default to 1M
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Cargo fmt
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
* Fix broken tests (on missing operation directory)
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
Co-authored-by: Wenzek <diw@softwareag.com>
Co-authored-by: Didier Wenzek <didier.wenzek@free.fr>
Diffstat (limited to 'crates/core/tedge_mapper/src/c8y_converter.rs')
| -rw-r--r-- | crates/core/tedge_mapper/src/c8y_converter.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/crates/core/tedge_mapper/src/c8y_converter.rs b/crates/core/tedge_mapper/src/c8y_converter.rs index ee85ade7..0fb6db98 100644 --- a/crates/core/tedge_mapper/src/c8y_converter.rs +++ b/crates/core/tedge_mapper/src/c8y_converter.rs @@ -4,7 +4,7 @@ use crate::{converter::*, operations::Operations}; use c8y_smartrest::alarm; use c8y_smartrest::smartrest_serializer::{SmartRestSerializer, SmartRestSetSupportedOperations}; use c8y_translator::json; -use mqtt_client::{Message, Topic}; +use mqtt_channel::{Message, Topic}; use std::collections::HashSet; use thin_edge_json::alarm::ThinEdgeAlarm; |