diff options
author | Marcel Müller <neikos@neikos.email> | 2024-04-04 11:50:40 +0200 |
---|---|---|
committer | Marcel Müller <neikos@neikos.email> | 2024-04-04 11:52:17 +0200 |
commit | 654587ad4efc2b0071826776c41064a96ea3754e (patch) | |
tree | a8a49b8e122b18c5422e600c9cba2fd146f4e4e4 | |
parent | fee2babb03001570b51233eb0b2d3ec08ff6390e (diff) |
Add Ping to cloudmqtt-bin
Signed-off-by: Marcel Müller <neikos@neikos.email>
-rw-r--r-- | cloudmqtt-bin/src/bin/client.rs | 4 |
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"); } |