diff --git a/src/queue/Sender.js b/src/queue/Sender.js index 626314d..63bc5d3 100644 --- a/src/queue/Sender.js +++ b/src/queue/Sender.js @@ -4,9 +4,9 @@ const QUEUE_HOST = "amqp://appointment:ZyuhJZ2xEYWhElhpJjy7YEpZGZwNYJz2fHIu@appo 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 = "TEST_QUEUE" // const TEST_QUEUE = "MORNING_DATA_CACHE" -const TEST_QUEUE = "SHARED_OBJECT" +// const TEST_QUEUE = "SHARED_OBJECT" class Sender { channel;p @@ -20,17 +20,11 @@ class Sender { await this.channel.assertQueue(REQUEST_DATA_QUEUE_FR, {persistent: true}); } - sendMessage(msg, queue_name = REQUEST_DATA_QUEUE_DE) { + sendMessage(msg, queue_name = REQUEST_DATA_QUEUE_FR) { this.channel.sendToQueue(queue_name, Buffer.from(msg),{ persistent:true }) } } -module.exports = {Sender, REQUEST_DATA_OBJECT, TEST_QUEUE} - -// let sender = new Sender() -// sender.initConnection().then((r) => { -// console.log(r) -// sender.sendMessage("test") -// }) +module.exports = {Sender, REQUEST_DATA_OBJECT, TEST_QUEUE} \ No newline at end of file