Page MenuHomePhabricator
Files F3341498

D13609.id44938.diff
No OneTemporary
Actions

D13609.id44938.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

File Metadata

Mime Type
text/plain
Expires
Fri, Nov 22, 11:09 PM (18 h, 5 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2563093
Default Alt Text
D13609.id44938.diff (744 B)

Event Timeline