From 7647cfc8d93aba99f5faef13eb3d970097540d76 Mon Sep 17 00:00:00 2001 From: Tom Date: Fri, 15 May 2026 12:17:36 -0700 Subject: [PATCH] fix: don't automatically set up rabbitmq in delta (#749) fix: don't declare queues which seem to cause the backend to crash in prod for now, these exchanges/queues/bindings will need to be declared manually. Hopefully the lapin rewrite will fix this. Signed-off-by: IAmTomahawkx --- crates/core/database/src/amqp/amqp.rs | 2 +- crates/delta/src/main.rs | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) 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());