D13609.diff
No OneTemporary
Actions

Size

744 B

Referenced Files

None

Subscribers

None

D13609.diff
View Options

	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