Unhandled rejection error: Channel ended, no reply will be forthcoming

[vunguyen11295]

"use strict"; const amqp = require('amqp-connection-manager'); const mqcon = require('./mqConnection'); const AMQP_URL = mqcon.getAMQPURL();

module.exports.success = function success(res, next, data) { _respond(res, next, 'success', data, 200); }

module.exports.failure = function failure(res, next, data, http_code) { _respond(res, next, 'failure', data, http_code); }

module.exports.publish = async function (msgKey, msgPayload) { const connection = await amqp.connect(AMQP_URL); const exch = 'taskch';

// Create a channel wrapper const channelWrapper = await connection.createChannel({ setup: channel => channel.assertExchange(exch, 'direct', { durable: true }) });

await channelWrapper.publish(exch, msgKey, Buffer.from(msgPayload)) .then(function () { // console.log("Message sent", msgPayload); }) .catch(err => { console.log("[ERROR] Message was rejected:", err.stack); channelWrapper.close(); connection.close(); });

};

module.exports.consume = async function (ex, qname, msgKey, invkFn) { const connection = await amqp.connect(AMQP_URL); const onMessage = data => { channelWrapper.ack(data); //call the function to be invoked on receipt of a message invkFn(data); }

// Set up a channel listening for messages in the queue. const channelWrapper = connection.createChannel({ setup: channel => Promise.all([ channel.assertExchange(ex, 'direct', { durable: true }), channel.assertQueue(qname, { exclusive: false }), // , autoDelete: true channel.bindQueue(qname, ex, msgKey), channel.consume(qname, onMessage) ]) });

channelWrapper.waitForConnect() .then(function () { console.log("[INFO] Waiting for messages in %s. To exit press CTRL+C", qname); }); }

This is my code, please help!

[nieverbe]

@vunguyen11295, Do you already have a solution for this? Seeing the same on my implementation..

[morigs]

Try to wrap await channelWrapper.waitForConnect() with try-catch (now you have only then without catch)

Also do not use await in await connection.createChannel. createChannel doesn't return a Promise

[dorshay6]

I am having a similar problem. It looks like it happens after logs of mirroring of messages inside the cluster, I think the channel state was not updated for some reason