-
Notifications
You must be signed in to change notification settings - Fork 5
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
"reliable" MQTT port (paho) #73
Conversation
…st-reliable-mqtt # Conflicts: # cerk_port_mqtt/Cargo.toml # cerk_port_mqtt/README.md # cerk_port_mqtt/src/lib.rs # cerk_runtime_threading/Cargo.toml
d209c56
to
0bf8bdc
Compare
@@ -1,6 +1,6 @@ | |||
[package] | |||
name = "cerk_port_mqtt" | |||
version = "0.2.6" | |||
version = "0.3.0" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this will be done in a separate release process
paho-mqtt = { version = "0.6.0", features = ["bundled", "build_bindgen"], default-features = false } | ||
paho-mqtt = { version="0.8.0", features=["bundled", "build_bindgen"], default-features = false} | ||
anyhow = "1.0" | ||
async-std = "1.7.0" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
async-std = "1.7.0" | |
async-std = "1.7" |
@@ -20,4 +20,6 @@ env_logger = "0.7.1" | |||
cerk = { version = "0.2", path = "../cerk" } | |||
cloudevents-sdk = "0.3.0" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
cloudevents-sdk = "0.3.0" | |
cloudevents-sdk = "0.3" |
match serde_json::from_str::<Event>(&payload_str) { | ||
Ok(cloud_event) => { | ||
debug!("{} deserialized event successfully", id); | ||
// todo add delivery attempt to routing id |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
open todo?
let routing_args = CloudEventRoutingArgs { | ||
delivery_guarantee: match connection.subscribe_qos { | ||
0 => DeliveryGuarantee::BestEffort, | ||
_ => panic!("The MQTT Port Currently only supports QoS 0 (see https://github.com/ce-rust/cerk/issues/71)"), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
add an error instead?
#[cfg(test)] | ||
mod tests { | ||
use super::*; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why have you removed all tests?
cerk_port_mqtt
IncomingCloudEventProcessed
andOutgoingCloudEventProcessed
)subscribe_topic
configurablesubscribe_qos
only supports value0
(see MQTT Port: Support for QoS 1/2 #71)persistence
not configurable anymore (always no persistence)cerk_runtime_threading