Cria arquivo producer e consumer para exibir a mensagem "Hello World"

Author: lucasgianine

package.json

@@ -5,7 +5,8 @@
   "main": "send.js",
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1",
-    "start": "node send.js && receive.js"
+    "producer": "node src/send.js",
+    "consumer": "node src/receive.js"
   },
   "keywords": [],
   "author": "",

src/receive.js

@@ -0,0 +1,24 @@
+const amqp = require('amqplib/callback_api')
+
+amqp.connect('amqp://localhost', (err, conn) => { // A configuração é a mesma que o send.js
+  if (err) throw err
+
+  conn.createChannel((err, channel) => {
+    if (err) throw err
+
+    // Declarando a queue no consumer
+    const queue = 'hello'
+
+    channel.assertQueue(queue, {
+      durable: false
+    })
+
+    console.log(` [*] Waiting for messages in ${queue}. To exit press CTRL+C`)
+
+    channel.consume(queue, (message) => { // Funciona de forma assíncrona, espera a mensage e só exibe assim que o RabbitMQ enviar para o consumer
+      console.log(` [x] Received: ${message.content.toString()}`)
+    }, {
+      noAck: true
+    })
+  })
+})

src/send.js

@@ -0,0 +1,25 @@
+const amqp = require('amqplib/callback_api')
+
+amqp.connect('amqp://localhost', (err, conn) => { // Criando conexão no servidor
+  if (err) throw err
+
+  conn.createChannel((err, channel) => { // Cria canal para desenvolver a maior parte da API
+    if (err) throw err
+
+    // Declarando queue/fila
+    const queue = 'hello'
+    const message = 'Hello World!'
+
+    channel.assertQueue(queue, {
+      durable: false
+    })
+
+    channel.sendToQueue(queue, Buffer.from(message)) // O conteúdo é um array de bytes
+    console.log(` [x] Sent: ${message}`)
+  })
+
+  setTimeout(() => {
+    conn.close()
+    process.exit(0)
+  }, 500) // Fecha conexão
+})