diff options
Diffstat (limited to 'plugins/jobs/brokers/amqp/redial.go')
| -rw-r--r-- | plugins/jobs/brokers/amqp/redial.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/jobs/brokers/amqp/redial.go b/plugins/jobs/brokers/amqp/redial.go index 16071b78..277e75b7 100644 --- a/plugins/jobs/brokers/amqp/redial.go +++ b/plugins/jobs/brokers/amqp/redial.go @@ -39,7 +39,7 @@ func (j *JobsConsumer) redialer() { //nolint:gocognit // re-init connection errInit := j.initRabbitMQ() if errInit != nil { - j.log.Error("error while redialing", "error", errInit) + j.log.Error("rabbitmq dial", "error", errInit) return errInit } @@ -74,7 +74,7 @@ func (j *JobsConsumer) redialer() { //nolint:gocognit // restart listener j.listener(deliv) - j.log.Info("queues and subscribers redeclare succeed") + j.log.Info("queues and subscribers redeclared successfully") return nil } |