#9 Encoders for MQTT

Author: sbcd90

Cargo.toml

@@ -46,12 +46,12 @@ members = [
   "cloudevents-sdk-reqwest",
   "cloudevents-sdk-rdkafka",
   "cloudevents-sdk-warp",
-  "cloudevents-sdk-mqtt"
+  "cloudevents-sdk-paho-mqtt"
 ]
 exclude = [
   "example-projects/actix-web-example",
   "example-projects/reqwest-wasm-example",
   "example-projects/rdkafka-example",
   "example-projects/warp-example",
-  "example-projects/mqtt-example"
+  "example-projects/paho-mqtt-example"
 ]

cloudevents-sdk-mqtt/Cargo.toml renamed to cloudevents-sdk-paho-mqtt/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "cloudevents-sdk-mqtt"
+name = "cloudevents-sdk-paho-mqtt"
 version = "0.3.0"
 authors = ["Francesco Guardiani <francescoguard@gmail.com>"]
 license-file = "../LICENSE"
@@ -11,7 +11,7 @@ description = "CloudEvents official Rust SDK - Mqtt integration"
 [dependencies]
 cloudevents-sdk = { version = "0.3.0", path = ".." }
 lazy_static = "1.4.0"
-paho-mqtt = { git = "https://github.com/eclipse/paho.mqtt.rust.git" }
+paho-mqtt = "0.8"
 chrono = { version = "^0.4", features = ["serde"] }
 
 [dev-dependencies]

cloudevents-sdk-mqtt/src/headers.rs renamed to cloudevents-sdk-paho-mqtt/src/headers.rs

@@ -1,5 +1,5 @@
 [package]
-name = "mqtt-example"
+name = "paho-mqtt-example"
 version = "0.2.0"
 authors = ["Subhobrata Dey <sbcd90@gmail.com>"]
 edition = "2018"
@@ -11,7 +11,7 @@ async-trait = "^0.1.33"
 cloudevents-sdk = { path = "../sdk-rust" }
 cloudevents-sdk-mqtt = { path = "../sdk-rust/cloudevents-sdk-mqtt"}
 env_logger = "0.7.1"
-paho-mqtt = { path = "../paho.mqtt.rust" }
+paho-mqtt = "0.8"
 serde_json = "^1.0"
 futures = "^0.3"
 tokio = { version = "^0.2", features = ["full"] }