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 a9f7d57 commit a13d284Copy full SHA for a13d284
package.json
@@ -1,6 +1,6 @@
1
{
2
"name": "@nestjstools/messaging-rabbitmq-extension",
3
- "version": "3.0.0",
+ "version": "3.0.1",
4
"description": "Extension to handle messages and dispatch them over AMQP protocol",
5
"author": "Sebastian Iwanczyszyn",
6
"private": false,
src/consumer/rabbitmq-messaging.consumer.ts
@@ -80,10 +80,10 @@ export class RabbitmqMessagingConsumer
80
}
81
82
async onModuleDestroy(): Promise<void> {
83
- if (this.channel) {
+ if (this.channel?.connection) {
84
await this.channel.connection.close();
85
- this.channel = undefined;
86
+ this.channel = undefined;
87
88
89
0 commit comments