Remove Clone on ProcessEventRequest

notifico-app/src/main.rs

@@ -40,6 +40,7 @@ use std::sync::Arc;
 use tracing::{debug, error, info, warn};
 use tracing_subscriber::{fmt, layer::SubscriberExt, util::SubscriberInitExt, EnvFilter};
 use url::Url;
+use uuid::Uuid;
 
 const COMPONENT_WORKER: &str = "worker";
 const COMPONENT_UI: &str = "ui";
@@ -117,12 +118,10 @@ async fn main() {
             #[allow(unused_assignments)]
             let mut amqp_client = None;
             if let Some(amqp_url) = args.amqp {
+                let container_name = format!("notifico-{}", Uuid::now_v7());
+
                 // Initialize AMQP client and replace local channels with AMQP ones
-                amqp_client = Some(
-                    AmqpClient::connect(amqp_url, "wrk".to_string())
-                        .await
-                        .unwrap(),
-                );
+                amqp_client = Some(AmqpClient::connect(amqp_url, container_name).await.unwrap());
 
                 let (amqp_pipelines_tx, amqp_pipelines_rx) = amqp_client
                     .as_mut()

notifico-core/src/pipeline/event.rs

@@ -12,7 +12,7 @@ use tracing::warn;
 use utoipa::ToSchema;
 use uuid::Uuid;
 
-#[derive(Serialize, Deserialize, ToSchema, Debug, Clone)]
+#[derive(Serialize, Deserialize, ToSchema, Debug)]
 pub struct ProcessEventRequest {
     #[serde(default = "Uuid::now_v7")]
     pub id: Uuid,

notifico-core/src/queue.rs

@@ -2,7 +2,6 @@ use async_trait::async_trait;
 use serde::{Deserialize, Serialize};
 use std::any::Any;
 use std::error::Error;
-use std::ops::Deref;
 use tokio::sync::oneshot;
 
 #[derive(Debug, Clone, Copy)]
@@ -22,7 +21,7 @@ pub trait SenderChannel: Send + Sync {
     async fn send_object(
         &self,
         message: Box<dyn Any + Send + Sync + 'static>,
-    ) -> Result<Outcome, Box<dyn std::error::Error>>;
+    ) -> Result<Outcome, Box<dyn Error>>;
     fn message_kind(&self) -> MessageKind;
 }
 
@@ -57,7 +56,7 @@ pub trait ReceiverChannel: Send + Sync {
 impl dyn ReceiverChannel {
     pub async fn receive<T>(&self) -> Result<(T, oneshot::Sender<Outcome>), Box<dyn Error>>
     where
-        T: for<'de> Deserialize<'de> + Send + Sync + Clone + Sized + 'static,
+        T: for<'de> Deserialize<'de> + Send + Sync + Sized + 'static,
     {
         let result = self.receive_object().await?;
         match self.message_kind() {
@@ -74,7 +73,7 @@ impl dyn ReceiverChannel {
             }
             MessageKind::Object => {
                 let message = result.0.downcast::<T>().unwrap();
-                Ok((message.deref().clone(), result.1))
+                Ok((*message, result.1))
             }
         }
     }