From 5d6faddce1c2c9d91e0127c38105e9c2d729a76d Mon Sep 17 00:00:00 2001 From: Dreaded_X Date: Thu, 24 Aug 2023 01:48:10 +0200 Subject: [PATCH] Increased mqtt queue size as a temporary fix --- src/main.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main.rs b/src/main.rs index 681d918..6ea7114 100644 --- a/src/main.rs +++ b/src/main.rs @@ -54,7 +54,8 @@ async fn app() -> anyhow::Result<()> { let config = Config::parse_file(&config_filename)?; // Create a mqtt client - let (client, eventloop) = AsyncClient::new(config.mqtt.clone(), 10); + // TODO: Since we wait with starting the eventloop we might fill the queue while setting up devices + let (client, eventloop) = AsyncClient::new(config.mqtt.clone(), 100); // Setup the device handler let device_manager = DeviceManager::new(client.clone());