Dreaded_X/automation_rs
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

Increased mqtt queue size as a temporary fix

Browse Source
This commit is contained in:
Dreaded_X 2023-08-24 01:48:10 +02:00
parent 9628b8a94b
commit 5d6faddce1
Signed by: Dreaded_X
GPG Key ID: FA5F485356B0D2D4
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main.rs
View File

@ -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());