diff --git a/src/building-blocks/rabbitmq/rabbitmq-connection.ts b/src/building-blocks/rabbitmq/rabbitmq-connection.ts index aa8c079..c286f4f 100644 --- a/src/building-blocks/rabbitmq/rabbitmq-connection.ts +++ b/src/building-blocks/rabbitmq/rabbitmq-connection.ts @@ -75,7 +75,6 @@ export class RabbitmqConnection implements OnModuleInit, IRabbitmqConnection { async closeConnection(): Promise { try { if (this.connection) { - await this.closeChanel(); await this.connection.close(); Logger.log('Connection closed successfully'); }