diff --git a/protocol/v2/ssv/validator/msgqueue_consumer.go b/protocol/v2/ssv/validator/msgqueue_consumer.go index 922f9091e8..3fb0f7b63b 100644 --- a/protocol/v2/ssv/validator/msgqueue_consumer.go +++ b/protocol/v2/ssv/validator/msgqueue_consumer.go @@ -33,9 +33,20 @@ func (v *Validator) HandleMessage(logger *zap.Logger, msg *queue.DecodedSSVMessa v.mtx.RLock() // read v.Queues defer v.mtx.RUnlock() - // logger.Debug("📬 handling SSV message", - // zap.Uint64("type", uint64(msg.MsgType)), - // fields.Role(msg.MsgID.GetRoleType())) + qbftMsg, ok := msg.Body.(*specqbft.Message) + if ok { + logger.Debug("📬 handling qbft message", + fields.QBFTMessageType(qbftMsg.MsgType), + fields.Height(qbftMsg.Height), + fields.Round(qbftMsg.Round), + fields.Role(msg.MsgID.GetRoleType()), + ) + } else { + logger.Debug("📬 handling non-qbft message", + fields.MessageType(msg.MsgType), + fields.Role(msg.MsgID.GetRoleType()), + ) + } if q, ok := v.Queues[msg.MsgID.GetRoleType()]; ok { if pushed := q.Q.TryPush(msg); !pushed {