Apply suggestion to internal/store/event_loop.go

6 years ago · 0998c67f20
parent 91ec7edc06
commit 0998c67f20
1 changed files with 1 additions and 1 deletions
--- a/internal/store/event_loop.go
+++ b/internal/store/event_loop.go
@ -406,7 +406,7 @@ func (loop *eventLoop) processMessages(eventLog *logrus.Entry, messages []*pmapi

 			if message.Created == nil {
 				msgLog.Error("Got EventCreate with nil message")
-				break
+				return errors.Wrap(err, "no message to put into DB")
 			}

 			if err = loop.store.createOrUpdateMessageEvent(message.Created); err != nil {