diff options
Diffstat (limited to 'plugins/jobs/drivers/amqp/redial.go')
-rw-r--r-- | plugins/jobs/drivers/amqp/redial.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/jobs/drivers/amqp/redial.go b/plugins/jobs/drivers/amqp/redial.go index 4f04484e..532aadb4 100644 --- a/plugins/jobs/drivers/amqp/redial.go +++ b/plugins/jobs/drivers/amqp/redial.go @@ -38,7 +38,7 @@ func (j *JobsConsumer) redialer() { //nolint:gocognit expb := backoff.NewExponentialBackOff() // set the retry timeout (minutes) expb.MaxElapsedTime = j.retryTimeout - op := func() error { + operation := func() error { j.log.Warn("rabbitmq reconnecting, caused by", "error", err) var dialErr error j.conn, dialErr = amqp.Dial(j.connStr) @@ -90,7 +90,7 @@ func (j *JobsConsumer) redialer() { //nolint:gocognit return nil } - retryErr := backoff.Retry(op, expb) + retryErr := backoff.Retry(operation, expb) if retryErr != nil { j.Unlock() j.log.Error("backoff failed", "error", retryErr) |