async connect(): Promise<void> {
        this.connection = await amqp.connect(process.env.RABBITMQ_URL ?? "");
        this.channel = await this.connection.createChannel();
        await this.channel.assertExchange(this.exchangeName, 'fanout', { durable: true });
        await this.channel.assertQueue(this.queueName, { durable: true });
        await this.channel.bindQueue(this.queueName, this.exchangeName, '');
        console.log('Connected to RabbitMQ');
        this.registerEvents();

        this.channel.consume(this.queueName, this.handleMessage.bind(this), { noAck: false });
    }