diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-31 11:54:24 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-31 11:54:24 +0300 |
| commit | 0c10cb989fa1deae3996df272f40e2270a880b52 (patch) | |
| tree | 6bc3bd0e56ffe8753933dd2957a3269ee578d5b8 /plugins/amqp/amqpjobs/redial.go | |
| parent | 0f5f9517f9b5bb79e265bbf7d9ee8ce4633cf9b4 (diff) | |
Finish boltdb tests
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/amqp/amqpjobs/redial.go')
| -rw-r--r-- | plugins/amqp/amqpjobs/redial.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/amqp/amqpjobs/redial.go b/plugins/amqp/amqpjobs/redial.go index 56142e2b..8d21784f 100644 --- a/plugins/amqp/amqpjobs/redial.go +++ b/plugins/amqp/amqpjobs/redial.go @@ -27,7 +27,7 @@ func (c *consumer) redialer() { //nolint:gocognit // trash the broken publishing channel <-c.publishChan - t := time.Now() + t := time.Now().UTC() pipe := c.pipeline.Load().(*pipeline.Pipeline) c.eh.Push(events.JobEvent{ @@ -35,7 +35,7 @@ func (c *consumer) redialer() { //nolint:gocognit Pipeline: pipe.Name(), Driver: pipe.Driver(), Error: err, - Start: time.Now(), + Start: time.Now().UTC(), }) expb := backoff.NewExponentialBackOff() |