diff --git a/services/tunnelbroker/src/amqp.rs b/services/tunnelbroker/src/amqp.rs
--- a/services/tunnelbroker/src/amqp.rs
+++ b/services/tunnelbroker/src/amqp.rs
@@ -56,21 +56,6 @@
   }
 }
 
-pub async fn connect() -> lapin::Connection {
-  let conn = create_connection()
-    .await
-    .expect("Unable to connect to AMQP. Exiting.");
-  conn.on_error(|error| {
-    tracing::error!(
-      errorType = error_types::AMQP_ERROR,
-      "Lapin error: {error:?}"
-    );
-  });
-
-  info!("Connected to AMQP endpoint: {}", &CONFIG.amqp_uri);
-  conn
-}
-
 /// Inner connection that is a direct wrapper over [`lapin::Connection`]
 /// This should be instantiated only once to establish connection
 /// New instances can be created to reconnect