feat(publish): with retain argument

EdJoPaTo · Jan 12, 2021 · d6a5f6c · d6a5f6c
1 parent a8a19bf
commit d6a5f6c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/cli.rs b/src/cli.rs
@@ -23,6 +23,12 @@ pub fn build() -> App<'static, 'static> {
                         .help("Payload to be published")
                         .required(true),
                 )
+                .arg(
+                    Arg::with_name("retain")
+                        .short("r")
+                        .long("retain")
+                        .help("Publish the MQTT message retained"),
+                )
                 .arg(
                     Arg::with_name("verbose")
                         .short("v")

diff --git a/src/main.rs b/src/main.rs
@@ -33,6 +33,7 @@ fn main() -> Result<(), Box<dyn Error>> {
 
     if let Some(matches) = matches.subcommand_matches("publish") {
         let verbose = matches.is_present("verbose");
+        let retain = matches.is_present("retain");
 
         let topic = matches
             .value_of("Topic")
@@ -42,7 +43,7 @@ fn main() -> Result<(), Box<dyn Error>> {
             .value_of("Payload")
             .expect("Topic could not be read from command line");
 
-        client.publish(topic, QoS::AtLeastOnce, false, payload)?;
+        client.publish(topic, QoS::AtLeastOnce, retain, payload)?;
 
         publish::eventloop(client, connection, verbose);
     } else {