We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7e7ddb9 commit da76951Copy full SHA for da76951
package.json
@@ -1,6 +1,6 @@
1
{
2
"name": "@nestjstools/messaging-rabbitmq-extension",
3
- "version": "3.1.0",
+ "version": "3.1.1",
4
"description": "Extension to handle messages and dispatch them over AMQP protocol",
5
"author": "Sebastian Iwanczyszyn",
6
"private": false,
src/channel/amqp.channel.ts
@@ -20,7 +20,9 @@ export class AmqpChannel extends Channel<ExtensionAmqpChannelConfig> {
20
21
this.connection = await amqp.connect(this.config.connectionUri);
22
this.connection.on('close', (err: any) => {
23
- console.error('AMQP Connection error:', err);
+ if (err) {
24
+ console.error('AMQP Connection error:', err);
25
+ }
26
process.exit(0);
27
});
28
}
0 commit comments