Fixed bug

subomi · subomi · commit 0af6e6b118ce · 2021-09-22T15:41:49.000+01:00
diff --git a/worker/producer.go b/worker/producer.go
@@ -68,6 +68,7 @@ func (p *Producer) postMessages(msgRepo convoy.MessageRepository, m convoy.Messa
 		bytes, err := json.Marshal(m.Data)
 		if err != nil {
 			log.Errorf("error occurred while parsing json")
+			return
 		}
 
 		bStr := string(bytes)

Original file line number	Diff line number	Diff line change
`@@ -68,6 +68,7 @@ func (p *Producer) postMessages(msgRepo convoy.MessageRepository, m convoy.Messa`
`68`	`68`	`bytes, err := json.Marshal(m.Data)`
`69`	`69`	`if err != nil {`
`70`	`70`	`log.Errorf("error occurred while parsing json")`
	`71`	`+ return`
`71`	`72`	`}`
`72`	`73`
`73`	`74`	`bStr := string(bytes)`