Downgrades messaging from module to fileHEADmaster

1 files changed, 10 insertions, 3 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>),
+}