diff --git a/src/queue/Sender.js b/src/queue/Sender.js index b24bfe8..4516fcf 100644 --- a/src/queue/Sender.js +++ b/src/queue/Sender.js @@ -5,6 +5,7 @@ const REQUEST_DATA_QUEUE_FR = 'REQUEST_DATA'; const REQUEST_DATA_QUEUE_DE = 'REQUEST_DATA_DE'; const REQUEST_DATA_OBJECT = "REQUEST_DATA_OBJECT" const TEST_QUEUE = "TEST_QUEUE" +// const TEST_QUEUE = "SHARED_OBJECT" class Sender { channel; @@ -19,7 +20,9 @@ class Sender { } sendMessage(msg, queue_name = REQUEST_DATA_QUEUE_FR) { - this.channel.sendToQueue(queue_name, Buffer.from(msg)) + this.channel.sendToQueue(queue_name, Buffer.from(msg),{ + persistent:true + }) } }