Skip to content

Loading…

connection kill does not emit error, exits process #88

Open
rschiavi opened this Issue · 1 comment

1 participant

@rschiavi

I have an app with simple connection created, with an exchange, and then just sits there.

If I then kill my rabbitmq-server in another shell, the demo amqp app just process exits, without any error notification.

Should this be working?

@rschiavi

Looking at line 836 of amqp.js, shouldn't that emit end or error/closed at least as well??

self.emit("end") ?? self.emit("error", "stream closed") ?? self.emit("closed")

self.addListener('end', function () {
self.end();
// in order to allow reconnects, have to clear the
// state.
parser = null;
});

Rich

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Something went wrong with that request. Please try again.