fix broken logging

Author: Bobonium

CHANGELOG.md

@@ -1,3 +1,7 @@
+# 0.8.1
+ 
+ - fix broken logging
+
 # 0.8.0
 
  - switch internal actor mailbox to `flume` from `crossbeam-channel`

src/actor/actor.rs

@@ -1,7 +1,7 @@
 use std::error::Error;
 use crate::prelude::{ActorContext, ActorPanicSource, ActorResult, SerializedMessage};
 use std::panic::UnwindSafe;
-use log::{debug, error};
+use log::{error};
 use crate::message::actor_stop_message::ActorStopMessage;
 
 /// Core trait to define Actors
@@ -446,7 +446,7 @@ pub trait Actor: Send + Sync + UnwindSafe + Sized {
     fn on_system_stop(&mut self, context: &ActorContext<Self>) -> Result<ActorResult, Box<dyn Error>> {
         let result = context.actor_ref.send(ActorStopMessage::new());
         if result.is_err() {
-            error!("Could not forward message ActorStopMessage to target {}", forward_to.get_address().actor);
+            error!("Could not forward message ActorStopMessage to target {}", context.actor_ref.get_address().actor);
         }
         return Ok(ActorResult::Ok);
     }

src/routers/round_robin_router.rs

@@ -157,7 +157,7 @@ where
         let forward_to = self.route_to.get(self.route_index).unwrap();
         let result = forward_to.send(msg.msg);
         if result.is_err() {
-            error!("Could not forward message {} to target {}", msg.get_id(), forward_to.get_address().actor);
+            error!("Could not forward message to target {}", forward_to.get_address().actor);
         }
         return Ok(ActorResult::Ok);
     }
@@ -187,7 +187,7 @@ where
             let chunk: Vec<M> = msg.data.drain(0..messages_per_routee).collect();
             let result = forward_to.send(BulkActorMessage::new(chunk));
             if result.is_err() {
-                error!("Could not forward message {} to target {}", msg.get_id(), forward_to.get_address().actor);
+                error!("Could not forward message to target {}", forward_to.get_address().actor);
             }
         }
         return Ok(ActorResult::Ok);

src/routers/sharded_router.rs

@@ -168,7 +168,7 @@ impl<A, M> Handler<RouterMessage<M>> for ShardedRouter<A>
         let forward_to = self.sharding.get(&shard_id).unwrap();
         let result = forward_to.send(msg.msg);
         if result.is_err() {
-            error!("Could not forward message {} to target {}", msg.get_id(), forward_to.get_address().actor);
+            error!("Could not forward message to target {}", forward_to.get_address().actor);
         }
         return Ok(ActorResult::Ok);
     }
@@ -193,7 +193,7 @@ impl<A, M> Handler<BulkRouterMessage<M>> for ShardedRouter<A>
             let chunk: Vec<M> = msg.data.drain(0..messages_per_routee).collect();
             let result = forward_to.send(BulkActorMessage::new(chunk));
             if result.is_err() {
-                error!("Could not forward message {} to target {}", msg.get_id(), forward_to.get_address().actor);
+                error!("Could not forward message to target {}", forward_to.get_address().actor);
             }
         }
         return Ok(ActorResult::Ok);

src/system/delay_actor.rs

@@ -35,7 +35,7 @@ impl<A, M> Handler<DelayedMessage<A, M>> for DelayActor
         if duration >= msg.delay {
             let result = msg.destination.send(msg.msg);
             if result.is_err() {
-                error!("Could not delay message {} to target {}", msg.get_id(), forward_to.get_address().actor);
+                error!("Could not delay message to target {}", msg.destination.get_address().actor);
             }
         }
         else {

src/system/internal_actor_manager.rs

@@ -37,7 +37,7 @@ impl InternalActorManager {
     {
         let result = self.delay_router.as_ref().unwrap().send(RouterMessage::new(DelayedMessage::new(msg, destination, duration)));
         if result.is_err() {
-            debug!("");
+            error!("Could not send message to delay router");
         }
     }