Adds checks if the amqp channel has an error and inits the connection again

parent 3ebd7e09
......@@ -34,6 +34,7 @@ class AMQPConnector {
this._channel = await this._connection.createChannel();
this._channel.on('error', error => {
console.error('Exception in amqp channel occured', error);
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment