Skip to content
Snippets Groups Projects

Resolve "Error handling in event publishing via entity services could be improved"

1 file
+ 1
0
Compare changes
  • Side-by-side
  • Inline
@@ -85,6 +85,7 @@ func (e *EventService) PublishEvent(topic string, event event.Event) error {
return nil
}
// RetryPublish is used to retry publishing an event after a failed attempt.
func (e *EventService) RetryPublish(topic string, event event.Event) error {
ctx := context.Background()
backOff := retry.NewConstant(2 * time.Second)
Loading