persist the message
This commit is contained in:
+4
-1
@@ -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
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user