diff options
Diffstat (limited to 'plugins/amqp')
| -rw-r--r-- | plugins/amqp/amqpjobs/consumer.go | 2 | ||||
| -rw-r--r-- | plugins/amqp/amqpjobs/redial.go | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/plugins/amqp/amqpjobs/consumer.go b/plugins/amqp/amqpjobs/consumer.go index 578f36ce..784a102c 100644 --- a/plugins/amqp/amqpjobs/consumer.go +++ b/plugins/amqp/amqpjobs/consumer.go @@ -479,7 +479,7 @@ func (c *consumer) handleItem(ctx context.Context, msg *Item) error { err = pch.Publish(c.exchangeName, tmpQ, false, false, amqp.Publishing{ Headers: table, ContentType: contentType, - Timestamp: time.Now().UTC(), + Timestamp: time.Now(), DeliveryMode: amqp.Persistent, Body: msg.Body(), }) 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() |