diff --git a/services/tunnelbroker/src/websockets/session.rs b/services/tunnelbroker/src/websockets/session.rs --- a/services/tunnelbroker/src/websockets/session.rs +++ b/services/tunnelbroker/src/websockets/session.rs @@ -270,7 +270,10 @@ .basic_consume( &device_info.device_id, RMQ_CONSUMER_TAG, - BasicConsumeOptions::default(), + BasicConsumeOptions { + no_ack: true, + ..Default::default() + }, FieldTable::default(), ) .await?;