Downgrades messaging from module to fileHEADmaster

2 files changed, 10 insertions, 14 deletions

diff --git a/rust/scraper/src/messaging/mod.rs b/rust/scraper/src/messaging.rs
index 947cab4..eea343d 100644
--- a/rust/scraper/src/messaging/mod.rs
+++ b/rust/scraper/src/messaging.rs
@@ -1,6 +1,3 @@
-mod error;
-
-use crate::messaging::error::MessagingError;
 use futures::StreamExt;
 use lapin::uri::AMQPUri;
 use lapin::{
@@ -10,9 +7,11 @@ use lapin::{
     Connection, ConnectionProperties,
 };
 use std::borrow::Cow;
+use thiserror::Error;
 use tokio::{
     sync::mpsc,
     sync::mpsc::{Receiver, Sender},
+    sync::mpsc::error::SendError
 };
 use tracing::{error, trace, warn};
 
@@ -149,3 +148,11 @@ impl Default for RabbitMQClientOptions {
         }
     }
 }
+
+#[derive(Error, Debug)]
+enum MessagingError {
+    #[error(transparent)]
+    LapinError(#[from] lapin::Error),
+    #[error(transparent)]
+    SendError(#[from] SendError<Delivery>),
+}
diff --git a/rust/scraper/src/messaging/error.rs b/rust/scraper/src/messaging/error.rs
deleted file mode 100644
index b68ea20..0000000
--- a/rust/scraper/src/messaging/error.rs
+++ /dev/null
@@ -1,11 +0,0 @@
-use lapin::message::Delivery;
-use thiserror::Error;
-use tokio::sync::mpsc::error::SendError;
-
-#[derive(Error, Debug)]
-pub enum MessagingError {
-    #[error(transparent)]
-    LapinError(#[from] lapin::Error),
-    #[error(transparent)]
-    SendError(#[from] SendError<Delivery>),
-}