Persist messages when sending to AMQP queue

kaizenjegan · Nov 22, 2017 · 1fc8f0f · 1fc8f0f
1 parent cf61cee
commit 1fc8f0f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/providers/queuing/amqpQueue.js b/providers/queuing/amqpQueue.js
@@ -69,7 +69,7 @@ class AmqpQueue {
       const body = JSON.stringify(request);
       const deferred = Q.defer();
       this.channel.then(channel => {
-        channel.sendToQueue(this.queueName, new Buffer(body), {}, (err, ok) => {
+        channel.sendToQueue(this.queueName, new Buffer(body), { persistent: true }, (err, ok) => {
           if (err) {
             return deferred.reject(err);
           }