Update gossip_actor.go

We currently log *actor.Stopping and *actor.Stopped as "Gossip received unknown message request"
asynkron · Dec 19, 2023 · 0c239cd · 0c239cd
1 parent a46b643
commit 0c239cd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cluster/gossip_actor.go b/cluster/gossip_actor.go
@@ -43,7 +43,7 @@ func NewGossipActor(requestTimeout time.Duration, myID string, getBlockedMembers
 // Receive method.
 func (ga *GossipActor) Receive(ctx actor.Context) {
 	switch r := ctx.Message().(type) {
-	case *actor.Started:
+	case *actor.Started, *actor.Stopping, *actor.Stopped:
 		// pass
 	case *SetGossipStateKey:
 		ga.onSetGossipStateKey(r, ctx)