diff options
Diffstat (limited to 'plugins/jobs/drivers/amqp/redial.go')
| -rw-r--r-- | plugins/jobs/drivers/amqp/redial.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/plugins/jobs/drivers/amqp/redial.go b/plugins/jobs/drivers/amqp/redial.go index ef2a130a..8dc18b8f 100644 --- a/plugins/jobs/drivers/amqp/redial.go +++ b/plugins/jobs/drivers/amqp/redial.go @@ -24,7 +24,7 @@ func (j *JobConsumer) redialer() { //nolint:gocognit j.Lock() - // trash the broken publish channel + // trash the broken publishing channel <-j.publishChan t := time.Now() @@ -85,6 +85,7 @@ func (j *JobConsumer) redialer() { //nolint:gocognit return errors.E(op, err) } + // put the fresh publishing channel j.publishChan <- pch // restart listener j.listener(deliv) |