Hope everyone is doing well.
Getting the following error on NodeJS Server when I try to publish to the queue.
NodeJS version - 14.18.2
I use following method to publish to the queue
Sample code to publish to queue
async function init()
{
const connection = await amqp.connect(config.rabbitmq.url);
const e = config.rabbitmq.exchange;
const channel = await connection.createChannel();
await channel.assertExchange(e, 'fanout', { durable:
false, autoDelete:
true });
channel.
publish(e, '', Buffer.
from(process.argv[2] || 'something to do'))
setTimeout(async () => {
await connection.close()
}, 500)
}
NOTE - I also use the following method with a time delay based on requirement.
Full error context:
Error: message nacked
at /home/node/node_modules/amqplib/lib/channel.js:34:16
at Array.forEach (<anonymous>)
at ConfirmChannel.C.handleConfirm (/home/node/node_modules/amqplib/lib/channel.js:358:15)
at ConfirmChannel.emit (events.js:400:28)
at ConfirmChannel.C.accept (/home/node/node_modules/amqplib/lib/channel.js:406:17)
at Connection.mainAccept [as accept] (/home/node/node_modules/amqplib/lib/connection.js:64:33)
at Socket.go (/home/node/node_modules/amqplib/lib/connection.js:478:48)
at Socket.emit (events.js:400:28)
at emitReadable_ (internal/streams/readable.js:555:12)
at processTicksAndRejections (internal/process/task_queues.js:81:21)
Any help is appreciated. Thanks
Neville