shyiko / amqplib-auto-recovery Goto Github PK

AMQP error Error: Channel ended, no reply will be forthcoming
    at rej (/Users/localadmin/workspace/nautilus-js/node_modules/amqplib/lib/channel.js:190:7)
    at Channel.C._rejectPending (/Users/localadmin/workspace/nautilus-js/node_modules/amqplib/lib/channel.js:196:42)
    at Channel.C.toClosed (/Users/localadmin/workspace/nautilus-js/node_modules/amqplib/lib/channel.js:160:8)
    at Channel.C.accept (/Users/localadmin/workspace/nautilus-js/node_modules/amqplib/lib/channel.js:411:10)
    at Connection.mainAccept [as accept] (/Users/localadmin/workspace/nautilus-js/node_modules/amqplib/lib/connection.js:63:33)
    at Socket.go (/Users/localadmin/workspace/nautilus-js/node_modules/amqplib/lib/connection.js:476:48)
    at emitNone (events.js:86:13)
    at Socket.emit (events.js:185:7)
    at emitReadable_ (_stream_readable.js:433:10)
    at emitReadable (_stream_readable.js:427:7)
    at readableAddChunk (_stream_readable.js:188:13)
    at Socket.Readable.push (_stream_readable.js:135:10)
    at TCP.onread (net.js:542:20)```

var amqp = require('amqplib');
var uuid = require('uuid-v4');

var url = 'amqp://localhost';
var rpc_queue = 'rpc_queue';

const REPLY_QUEUE = 'amq.rabbitmq.reply-to';
 
const createClient = () => amqp.connect(url)
  .then((conn) => conn.createChannel())
  .then((channel) => {
    console.log('channel created');
    // create an event emitter where rpc responses will be published by correlationId
    channel.responseEmitter = new EventEmitter();
    channel.responseEmitter.setMaxListeners(0);
    channel.consume(REPLY_QUEUE,
      (msg) => channel.responseEmitter.emit(msg.properties.correlationId, msg.content),
      {noAck: true});
 
    return channel;
  });

async function test() {
 var channel = await createClient();
};

test();

 '(node:15384) UnhandledPromiseRejectionWarning: TypeError: Cannot read property 'then' of undefined' 
and
 if (err === null) cb(null, new CallbackModel(c));
                      ^
TypeError: cb is not a function