diff --git a/src/engine/engine/plugin.rs b/src/engine/engine/plugin.rs
index f620822..990e18f 100644
--- a/src/engine/engine/plugin.rs
+++ b/src/engine/engine/plugin.rs
@@ -65,13 +65,12 @@ impl StrategyEngine {
             .upgrade()
             .expect("Failed to upgrade engine (StrategyEngine)");
 
-        let strategy = self.strategy.clone();
-        let risk = self.risk.clone();
-
-        strategy.send(&StrategyEngineMessage::Initialize).await?;
+        self.strategy
+            .send(&StrategyEngineMessage::Initialize)
+            .await?;
 
         loop {
-            match strategy.recv().await? {
+            match self.strategy.recv().await? {
                 None => {}
 
                 Some(StrategyMessage::GetWatchList) => {
@@ -88,7 +87,7 @@ impl StrategyEngine {
                 }
 
                 Some(StrategyMessage::Signal(signal)) => {
-                    risk.send(&RiskEngineMessage::Signal(signal)).await?;
+                    self.risk.send(&RiskEngineMessage::Signal(signal)).await?;
                 }
 
                 Some(StrategyMessage::Subscribe(subscription)) => {
@@ -152,12 +151,10 @@ impl StrategyEngine {
             .upgrade()
             .expect("Failed to upgrade engine (StrategyEngine)");
 
-        let risk = self.risk.clone();
-
-        risk.send(&RiskEngineMessage::Initialize).await?;
+        self.risk.send(&RiskEngineMessage::Initialize).await?;
 
         loop {
-            match risk.recv().await? {
+            match self.risk.recv().await? {
                 None => {}
 
                 Some(RiskMessage::GetWatchList) => {