diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-23 15:51:54 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-23 15:51:54 +0300 |
| commit | e88dfd5cd10662f0ad68e69f9d9de2f66ddf26d0 (patch) | |
| tree | 0f5c18d6c1205d7499523a35740f4054a9aa9904 /plugins | |
| parent | 9079cc51599d6e21ac59e34573f7bbf2e2e87b9e (diff) | |
Add AMQP initial durability test
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins')
| -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 |