panleicim/puppeteerjs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

support more texts

Browse Source
This commit is contained in:
Lei PAN
2024-04-23 23:38:53 +02:00
parent 4c80f75f31
commit 7c1c36da13
1 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/queue/Sender.js
+4 -10
View File
@@ -4,9 +4,9 @@ const QUEUE_HOST = "amqp://appointment:ZyuhJZ2xEYWhElhpJjy7YEpZGZwNYJz2fHIu@appo
const REQUEST_DATA_QUEUE_FR = 'REQUEST_DATA'; const REQUEST_DATA_QUEUE_FR = 'REQUEST_DATA';
const REQUEST_DATA_QUEUE_DE = 'REQUEST_DATA_DE'; const REQUEST_DATA_QUEUE_DE = 'REQUEST_DATA_DE';
const REQUEST_DATA_OBJECT = "REQUEST_DATA_OBJECT" 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 = "MORNING_DATA_CACHE"
const TEST_QUEUE = "SHARED_OBJECT" // const TEST_QUEUE = "SHARED_OBJECT"
class Sender { class Sender {
channel;p channel;p
@@ -20,17 +20,11 @@ class Sender {
await this.channel.assertQueue(REQUEST_DATA_QUEUE_FR, {persistent: true}); 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),{ this.channel.sendToQueue(queue_name, Buffer.from(msg),{
persistent:true persistent:true
}) })
} }
} }
module.exports = {Sender, REQUEST_DATA_OBJECT, TEST_QUEUE} module.exports = {Sender, REQUEST_DATA_OBJECT, TEST_QUEUE}
// let sender = new Sender()
// sender.initConnection().then((r) => {
// console.log(r)
// sender.sendMessage("test")
// })