diff --git a/src/clients/supervisor_hub.rs b/src/clients/supervisor_hub.rs index daee7b4..3737803 100644 --- a/src/clients/supervisor_hub.rs +++ b/src/clients/supervisor_hub.rs @@ -48,7 +48,7 @@ impl SupervisorHub { fn spawn_pop_loop(hub: Arc) { tokio::spawn(async move { loop { - match hub.mycelium.pop_message(Some(false), Some(2), None).await { + match hub.mycelium.pop_message(Some(false), Some(20), None).await { Ok(Some(inb)) => { // Extract and decode payload let Some(payload_b64) = inb.get("payload").and_then(|v| v.as_str()) else {