diff --git a/api/src/services/queue.service.ts b/api/src/services/queue.service.ts index aefea5f..c7ec547 100644 --- a/api/src/services/queue.service.ts +++ b/api/src/services/queue.service.ts @@ -130,8 +130,6 @@ class RabbitQueueService implements QueueService { return this.channel; } - this.channel?.recover - try { const connection = await ampqlib.connect(`amqp://${RABBITMQ_HOST}`); const channel = await connection.createChannel();