1 files changed, 1 insertions, 1 deletions
diff --git a/src/main.rs b/src/main.rs
index bc59b0b..0ba13f4 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -75,7 +75,7 @@ async fn main() -> anyhow::Result<()> {
     let (client, mut event_loop) = conf.mqtt_client();
     for topic in conf.routes.keys() {
         // TODO: Configurable subscription QoS
-        if let Err(e) = client.subscribe(topic, QoS::AtMostOnce).await {
+        if let Err(e) = client.subscribe(topic, QoS::ExactlyOnce).await {
             eprintln!("warning: Failed to subscribe to '{topic}': {e:?}");
         }
     }