diff --git a/services/tunnelbroker/src/websockets/mod.rs b/services/tunnelbroker/src/websockets/mod.rs --- a/services/tunnelbroker/src/websockets/mod.rs +++ b/services/tunnelbroker/src/websockets/mod.rs @@ -18,7 +18,7 @@ use std::pin::Pin; use tokio::io::{AsyncRead, AsyncWrite}; use tokio::net::TcpListener; -use tracing::{debug, error, info}; +use tracing::{debug, error, info, trace}; use tunnelbroker_messages::{ ConnectionInitializationStatus, Heartbeat, MessageSentStatus, MessageToDeviceRequestStatus, @@ -229,7 +229,7 @@ // Poll for messages either being sent to the device (rx) // or messages being received from the device (incoming) loop { - debug!("Polling for messages from: {}", addr); + trace!("Polling for messages from: {}", addr); tokio::select! { Some(Ok(delivery)) = session.next_amqp_message() => { if let Ok(message) = std::str::from_utf8(&delivery.data) { 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 @@ -18,7 +18,7 @@ use lapin::BasicProperties; use tokio::io::AsyncRead; use tokio::io::AsyncWrite; -use tracing::{debug, error, info}; +use tracing::{debug, error, info, trace}; use tunnelbroker_messages::{ message_to_device_request_status::Failure, message_to_device_request_status::MessageSentStatus, session::DeviceTypes, @@ -292,7 +292,7 @@ match serialized_message { Messages::Heartbeat(Heartbeat {}) => { - debug!("Received heartbeat from: {}", self.device_info.device_id); + trace!("Received heartbeat from: {}", self.device_info.device_id); None } Messages::MessageReceiveConfirmation(confirmation) => {