summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMarcel Müller <neikos@neikos.email>2024-04-04 11:50:40 +0200
committerMarcel Müller <neikos@neikos.email>2024-04-04 11:52:17 +0200
commit654587ad4efc2b0071826776c41064a96ea3754e (patch)
treea8a49b8e122b18c5422e600c9cba2fd146f4e4e4
parentfee2babb03001570b51233eb0b2d3ec08ff6390e (diff)
Add Ping to cloudmqtt-bin
Signed-off-by: Marcel Müller <neikos@neikos.email>
-rw-r--r--cloudmqtt-bin/src/bin/client.rs4
1 files changed, 3 insertions, 1 deletions
diff --git a/cloudmqtt-bin/src/bin/client.rs b/cloudmqtt-bin/src/bin/client.rs
index 4d5667e..7537cc3 100644
--- a/cloudmqtt-bin/src/bin/client.rs
+++ b/cloudmqtt-bin/src/bin/client.rs
@@ -6,7 +6,7 @@
use clap::Parser;
use cloudmqtt::client::connect::MqttClientConnector;
-use cloudmqtt::client::publish::Publish;
+use cloudmqtt::client::send::Publish;
use cloudmqtt::client::MqttClient;
use cloudmqtt::transport::MqttConnectTransport;
use tokio::net::TcpStream;
@@ -67,5 +67,7 @@ async fn main() {
.acknowledged()
.await;
+ client.ping().await.unwrap().response().await;
+
println!("Sent message! Bye");
}