From 0be3e79115345d13e92da9b8a4e2b0926480c138 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Mon, 12 Jul 2021 12:55:04 +0300 Subject: Return proper error type in the redial Signed-off-by: Valery Piashchynski --- plugins/jobs/brokers/amqp/redial.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/plugins/jobs/brokers/amqp/redial.go b/plugins/jobs/brokers/amqp/redial.go index 571ee548..6ce69ed9 100644 --- a/plugins/jobs/brokers/amqp/redial.go +++ b/plugins/jobs/brokers/amqp/redial.go @@ -1,7 +1,6 @@ package amqp import ( - "fmt" "time" "github.com/cenkalti/backoff/v4" @@ -45,7 +44,7 @@ func (j *JobsConsumer) redialer() { //nolint:gocognit var dialErr error j.conn, dialErr = amqp.Dial(j.connStr) if dialErr != nil { - return fmt.Errorf("fail to dial server endpoint: %v", dialErr) + return errors.E(op, dialErr) } j.log.Info("rabbitmq dial succeed. trying to redeclare queues and subscribers") -- cgit v1.2.3