Skip to content

Instantly share code, notes, and snippets.

@matheuspl
matheuspl / rabbit-graceful-shutdown.js
Created April 29, 2024 09:13 — forked from eduardo-matos/rabbit-graceful-shutdown.js
RabbitMQ graceful shutdown in NodeJS
const amqp = require('amqplib');
const uuid = require('uuid')
const CONSUMER_TAG = uuid.v4();
const QUEUE_NAME = 'my_queue'
async function main() {
const conn = await amqp.connect('amqp://guest:guest@localhost:5672/%2F');
const channel = await conn.createChannel();
await channel.assertQueue(QUEUE_NAME);
{
"transfer": "Transferu",
"transfer_feed": "Transfer Feed",
"change_name": "Change Name"
}
{
"transfer": "Transferu",
"transfer_feed": "Transfer Feed",
"change_name": "Change Name"
}