Skip to content

Commit

Permalink
Merge branch 'master' into redis-metrics
Browse files Browse the repository at this point in the history
  • Loading branch information
Reasno authored Apr 27, 2021
2 parents 826a36f + 37893d4 commit 961081d
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion queue/dispatcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ func (d *QueueableDispatcher) work(ctx context.Context, msg *PersistedEvent) {
_ = d.driver.Retry(context.Background(), msg)
return
}
_ = level.Warn(d.logger).Log("err", errors.Wrapf(err, "event %s failed after %d Attempts, aborted", msg.Key, msg.MaxAttempts))
_ = level.Warn(d.logger).Log("err", errors.Wrapf(err, "event %s failed after %d attempts, aborted", msg.Key, msg.MaxAttempts))
_ = d.Dispatch(context.Background(), events.Of(AbortedEvent{Err: err, Msg: msg}))
_ = d.driver.Fail(context.Background(), msg)
return
Expand Down

0 comments on commit 961081d

Please sign in to comment.