diff --git a/crates/daemons/searchd/src/consumers/channel_delete.rs b/crates/daemons/searchd/src/consumers/channel_delete.rs
index dce1b2b8..170f8189 100644
--- a/crates/daemons/searchd/src/consumers/channel_delete.rs
+++ b/crates/daemons/searchd/src/consumers/channel_delete.rs
@@ -1,6 +1,6 @@
 use amqprs::{BasicProperties, Deliver, channel::{BasicAckArguments, Channel}, consumer::AsyncConsumer};
 use async_trait::async_trait;
-use revolt_database::events::rabbit::{ChannelDeletePayload, MessageDeletePayload};
+use revolt_database::events::rabbit::ChannelDeletePayload;
 use revolt_search::ElasticsearchClient;
 
 pub struct ChannelDeleteConsumer(pub ElasticsearchClient);
diff --git a/crates/daemons/searchd/src/consumers/mod.rs b/crates/daemons/searchd/src/consumers/mod.rs
index f51eab9c..dc4e3ff3 100644
--- a/crates/daemons/searchd/src/consumers/mod.rs
+++ b/crates/daemons/searchd/src/consumers/mod.rs
@@ -1,8 +1,9 @@
-mod message;
-mod message_edit;
-mod message_delete;
 mod channel_delete;
+mod message;
+mod message_delete;
+mod message_edit;
 
+pub use channel_delete::*;
 pub use message::*;
+pub use message_delete::*;
 pub use message_edit::*;
-pub use channel_delete::*;
\ No newline at end of file
diff --git a/crates/daemons/searchd/src/main.rs b/crates/daemons/searchd/src/main.rs
index feca829c..ae0bb1d0 100644
--- a/crates/daemons/searchd/src/main.rs
+++ b/crates/daemons/searchd/src/main.rs
@@ -70,7 +70,7 @@ async fn _main() {
             &config,
             &connection,
             &config.elasticsearch.message_delete_queue,
-            consumers::MessageConsumer(client.clone()),
+            consumers::MessageDeleteConsumer(client.clone()),
         )
         .await,
     );
diff --git a/crates/delta/src/routes/channels/message_delete.rs b/crates/delta/src/routes/channels/message_delete.rs
index 9b1ba4ee..1f5f0911 100644
--- a/crates/delta/src/routes/channels/message_delete.rs
+++ b/crates/delta/src/routes/channels/message_delete.rs
@@ -1,4 +1,3 @@
-use revolt_config::capture_error;
 use revolt_database::{
     AMQP, Database, User, util::{permissions::DatabasePermissionQuery, reference::Reference}
 };