Fix mailbox post user message type check on message envelope asynkron…

…#599
Kunduin · Jan 21, 2023 · 8f7b39c · 8f7b39c
1 parent 54ea902
commit 8f7b39c
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/actor/mailbox.go b/actor/mailbox.go
@@ -63,6 +63,7 @@ func (m *defaultMailbox) PostUserMessage(message interface{}) {
 	}
 
 	// is it an envelope batch message?
+	// FIXME: check if this is still needed, maybe MessageEnvelope can only exist as a pointer
 	if env, ok := message.(MessageEnvelope); ok {
 		if batch, ok := env.Message.(MessageBatch); ok {
 			messages := batch.GetMessages()
@@ -72,6 +73,15 @@ func (m *defaultMailbox) PostUserMessage(message interface{}) {
 			}
 		}
 	}
+	if env, ok := message.(*MessageEnvelope); ok {
+		if batch, ok := env.Message.(MessageBatch); ok {
+			messages := batch.GetMessages()
+
+			for _, msg := range messages {
+				m.PostUserMessage(msg)
+			}
+		}
+	}
 
 	// normal messages
 	for _, ms := range m.middlewares {

diff --git a/actor/process_registry.go b/actor/process_registry.go
@@ -3,7 +3,7 @@ package actor
 import (
 	"sync/atomic"
 
-	murmur32 "github.com/spaolacci/murmur3"
+	murmur32 "github.com/twmb/murmur3"
 
 	cmap "github.com/orcaman/concurrent-map"
 )