summaryrefslogtreecommitdiff
path: root/plugins/jobs
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-07-10 11:20:25 +0300
committerValery Piashchynski <[email protected]>2021-07-10 11:20:25 +0300
commita90c34e163cd71980a63685d69a97cce3d72505d (patch)
tree419f09d48a8bcd7f817e6f3f42034e6922715aad /plugins/jobs
parent96d437f96785ada6aa5eb6d6ec9505b977ab3e74 (diff)
DeliveryMode -> amqp.Persistent
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs')
-rw-r--r--plugins/jobs/brokers/amqp/consumer.go9
1 files changed, 5 insertions, 4 deletions
diff --git a/plugins/jobs/brokers/amqp/consumer.go b/plugins/jobs/brokers/amqp/consumer.go
index ccf6b2ea..7fcf4013 100644
--- a/plugins/jobs/brokers/amqp/consumer.go
+++ b/plugins/jobs/brokers/amqp/consumer.go
@@ -181,10 +181,11 @@ func (j *JobsConsumer) Push(job *structs.Job) error {
// insert to the local, limited pipeline
err = j.publishChan.Publish(j.exchangeName, tmpQ, false, false, amqp.Publishing{
- Headers: pack(job.Ident, msg),
- ContentType: contentType,
- Timestamp: time.Now(),
- Body: msg.Body(),
+ Headers: pack(job.Ident, msg),
+ ContentType: contentType,
+ Timestamp: time.Now(),
+ DeliveryMode: amqp.Persistent,
+ Body: msg.Body(),
})
if err != nil {