diff options
Diffstat (limited to 'plugins/jobs/drivers/amqp/redial.go')
| -rw-r--r-- | plugins/jobs/drivers/amqp/redial.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/amqp/redial.go b/plugins/jobs/drivers/amqp/redial.go index 532aadb4..47afdcb3 100644 --- a/plugins/jobs/drivers/amqp/redial.go +++ b/plugins/jobs/drivers/amqp/redial.go @@ -26,6 +26,7 @@ func (j *JobsConsumer) redialer() { //nolint:gocognit t := time.Now() pipe := j.pipeline.Load().(*pipeline.Pipeline) + j.eh.Push(events.JobEvent{ Event: events.EventPipeError, Pipeline: pipe.Name(), @@ -34,7 +35,6 @@ func (j *JobsConsumer) redialer() { //nolint:gocognit Start: time.Now(), }) - j.log.Error("connection closed, reconnecting", "error", err) expb := backoff.NewExponentialBackOff() // set the retry timeout (minutes) expb.MaxElapsedTime = j.retryTimeout |