Skip to content
Snippets Groups Projects
Commit 8a1622c4 authored by Benjamin Wenger's avatar Benjamin Wenger
Browse files

improved the crash fix

parent e21e6d6a
Branches
Tags
1 merge request!117Release
Show whitespace changes
Inline Side-by-side
storage/utility/messageBuffer.go
+ 1
− 0
View file @ 8a1622c4
...@@ -270,6 +270,7 @@ func (mb *MessageBuffer) Next() (interface{}, bool) { ...@@ -270,6 +270,7 @@ func (mb *MessageBuffer) Next() (interface{}, bool) {
// Retrieve the message for storage // Retrieve the message for storage
m, err = mb.handler.LoadMessage(mb.kv, makeStoredMessageKey(mb.key, h)) m, err = mb.handler.LoadMessage(mb.kv, makeStoredMessageKey(mb.key, h))
if err != nil { if err != nil {
m=nil
jww.ERROR.Printf("Failed to load message %s from store, "+ jww.ERROR.Printf("Failed to load message %s from store, "+
"this may happen on occasion due to replays to increase "+ "this may happen on occasion due to replays to increase "+
"reliability: %v", h, err) "reliability: %v", h, err)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment