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/consumer.go | |
| parent | 0f5f9517f9b5bb79e265bbf7d9ee8ce4633cf9b4 (diff) | |
Finish boltdb tests
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/amqp/amqpjobs/consumer.go')
| -rw-r--r-- | plugins/amqp/amqpjobs/consumer.go | 2 |
1 files changed, 1 insertions, 1 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(), }) |