diff --git a/beacon-chain/sync/subscriber.go b/beacon-chain/sync/subscriber.go index a5afa1254..794f94e0f 100644 --- a/beacon-chain/sync/subscriber.go +++ b/beacon-chain/sync/subscriber.go @@ -158,6 +158,10 @@ func (r *Service) subscribe(topic string, validator pubsub.Validator, handle sub continue } + if msg.ReceivedFrom == r.p2p.PeerID() { + continue + } + messageReceivedCounter.WithLabelValues(topic + r.p2p.Encoding().ProtocolSuffix()).Inc() go pipeline(msg)