postwait / node-amqp

[UNMAINTAINED] node-amqp is an AMQP client for nodejs
MIT License
1.7k stars 357 forks source link

Connection Breaking if RabbitMQ is down #443

Open slota opened 7 years ago

slota commented 7 years ago

Hello, I'm trying to have our program use withAutoRecovery and continue to reconnect to rabbit if rabbit is down, we are currently receiving this issue,

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)