Managing Reconnections and Error Handling in amqplib Connections

export const createRabbitMQConnection = (config: QueueConfig, logger: Logger) =>
  Effect.acquireRelease(
    Effect.gen(function* () {
      yield* logger.info('Creating RabbitMQ connection');
      const connection = yield* Effect.tryPromise(() => amqp.connect(config.url));
      yield* logger.info('RabbitMQ connection created successfully');
      return connection;
    }).pipe(
      Effect.mapError((error) => {
        const errorMessage = error instanceof Error ? error.cause : String(error);
        return new QueueConnectionFailedError({
          reason: `Failed to create RabbitMQ Connection: ${errorMessage}`,
        });
      })
    ),
    (connection) =>
      Effect.promise(() => connection.close()).pipe(
        Effect.tap(() => logger.info('RabbitMQ connection closed successfully')),
        Effect.tapError((error) => logger.error(`Error closing RabbitMQ connection: ${error}`)),
        Effect.ignore
      )
  );

export const createRabbitMQConnection = (config: QueueConfig, logger: Logger) =>
  Effect.acquireRelease(
    Effect.gen(function* () {
      yield* logger.info('Creating RabbitMQ connection');
      const connection = yield* Effect.tryPromise(() => amqp.connect(config.url));
      yield* logger.info('RabbitMQ connection created successfully');
      return connection;
    }).pipe(
      Effect.mapError((error) => {
        const errorMessage = error instanceof Error ? error.cause : String(error);
        return new QueueConnectionFailedError({
          reason: `Failed to create RabbitMQ Connection: ${errorMessage}`,
        });
      })
    ),
    (connection) =>
      Effect.promise(() => connection.close()).pipe(
        Effect.tap(() => logger.info('RabbitMQ connection closed successfully')),
        Effect.tapError((error) => logger.error(`Error closing RabbitMQ connection: ${error}`)),
        Effect.ignore
      )
  );