Complete the sender field of deadletters object. asynkron#60

killgxlin · Jan 5, 2017 · f2bba42 · f2bba42
1 parent 25742be
commit f2bba42
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/actor/deadletter.go b/actor/deadletter.go
@@ -9,12 +9,14 @@ var (
 type DeadLetter struct {
 	PID     *PID
 	Message interface{}
+	Sender  *PID
 }
 
 func (*DeadLetterActorRef) SendUserMessage(pid *PID, message interface{}, sender *PID) {
 	EventStream.Publish(&DeadLetter{
 		PID:     pid,
 		Message: message,
+		Sender:  sender,
 	})
 }
 

diff --git a/actor/event_stream.go b/actor/event_stream.go
@@ -23,7 +23,7 @@ type Subscription struct {
 func init() {
 	EventStream.Subscribe(func(msg interface{}) {
 		if deadLetter, ok := msg.(*DeadLetter); ok {
-			log.Printf("[DeadLetter] %v got %+v", deadLetter.PID, deadLetter.Message)
+			log.Printf("[DeadLetter] %v got %+v from %v", deadLetter.PID, deadLetter.Message, deadLetter.Sender)
 		}
 	})
 }