Page MenuHomePhabricator
Files F2888830

D13609.id44889.diff
No OneTemporary
Actions

D13609.id44889.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
@@ -57,21 +57,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

File Metadata

Mime Type
text/plain
Expires
Sat, Oct 5, 5:47 AM (8 h, 21 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2236170
Default Alt Text
D13609.id44889.diff (744 B)

Event Timeline