diff --git a/storage/utility/messageBuffer.go b/storage/utility/messageBuffer.go index 05492c33bd3b04de96d911ec6b84b411a50fbc27..501a969c4c5c5429936ed0201e1b29f9632c8f74 100644 --- a/storage/utility/messageBuffer.go +++ b/storage/utility/messageBuffer.go @@ -309,10 +309,10 @@ func (mb *MessageBuffer) Next() (interface{}, bool) { "reliability: %v", h, err) } - mhash := mb.handler.HashMessage(m) - if mhash != h { - jww.ERROR.Printf("MessageHash mismatch:\n%v\n%v", - mhash, h) + if m != nil && h != mb.handler.HashMessage(m) { + jww.WARN.Printf("MessageHash mismatch, possible"+ + " deserialization failure: %v != %v", + mb.handler.HashMessage(m), h) } }