From 8484e634f335e7dff0ad473538066b64576d540e Mon Sep 17 00:00:00 2001 From: Lei PAN Date: Fri, 29 Mar 2024 15:13:59 +0100 Subject: [PATCH] persist the message --- src/queue/Sender.js | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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 + }) } }