diff --git a/internal/broker/cluster/swarm.go b/internal/broker/cluster/swarm.go index 0c7b1dbd..33bf98c8 100644 --- a/internal/broker/cluster/swarm.go +++ b/internal/broker/cluster/swarm.go @@ -312,8 +312,8 @@ func (s *Swarm) OnGossipUnicast(src mesh.PeerName, buf []byte) (err error) { } // Go through each message in the decoded frame - for _, m := range frame { - s.OnMessage(&m) + for i := range frame { + s.OnMessage(&frame[i]) } return nil