diff --git a/pkg/consensus/consensus.go b/pkg/consensus/consensus.go index a4e06ba93..c0a74e666 100644 --- a/pkg/consensus/consensus.go +++ b/pkg/consensus/consensus.go @@ -283,7 +283,7 @@ func (s *service) OnPayload(cp *Payload) { } // decode payload data into message - if cp.message == nil { + if cp.message.payload == nil { if err := cp.decodeData(); err != nil { log.Debug("can't decode payload data") return