diff --git a/crates/core/database/src/amqp/amqp.rs b/crates/core/database/src/amqp/amqp.rs index 16326045..e0c644e5 100644 --- a/crates/core/database/src/amqp/amqp.rs +++ b/crates/core/database/src/amqp/amqp.rs @@ -47,7 +47,7 @@ impl AMQP { .expect("Failed to open RabbitMQ channel"); let mut resp = AMQP::new(connection, channel); - resp.configure_channels().await?; + //resp.configure_channels().await?; Ok(resp) } diff --git a/crates/delta/src/main.rs b/crates/delta/src/main.rs index e3cf43a4..15aa2d3b 100644 --- a/crates/delta/src/main.rs +++ b/crates/delta/src/main.rs @@ -120,9 +120,9 @@ pub async fn web() -> Rocket { .expect("Failed to declare exchange"); let mut amqp = AMQP::new(connection, channel); - amqp.configure_channels() - .await - .expect("Failed to configure channels"); + // amqp.configure_channels() + // .await + // .expect("Failed to configure channels"); // Launch background task workers revolt_database::tasks::start_workers(db.clone(), amqp.clone());