Correct Usage of acquireRelease in Redis and BullMq Services

const make = Effect.gen(function* () {
    const { host, port } = yield* RedisConfig;
    const runtime = yield* Effect.runtime();

    const redis = yield* Effect.acquireRelease(
        Effect.sync(() => {
            return new Redis({
                ...
            });
        }),
        (redis) => Effect.sync(() => redis.disconnect())
    );

    // ... setup event listeners
});

export class RedisService ... {
    static readonly Live = Layer.scoped(this, make);
}

const make = Effect.gen(function* () {
    const redisService = yield* RedisService;

    const createQueue = <DataType = any, ResultType = any, NameType extends string = string>(
        name: QueueName,
        opts?: QueueOptions
    ) =>
        Effect.acquireRelease(
            Effect.try({
                try: () =>
                    new Queue<DataType, ResultType, NameType>(name, {
                        connection: redisService.redis,
                        ...opts
                    }),
                catch: (error) =>
                    ...
            }),
            (queue) => Effect.sync(() => queue.close())
        );

    return { createQueue };
});

export class BullMqQueueService ... {
    static readonly Live = Layer.effect(this, make).pipe(Layer.provide(RedisService.Live));
}

const make = Effect.gen(function* (_) {
    const queueService = yield* BullMqQueueService;
    const userQueue = yield* queueService.createQueue<UserJobData, UserJobResult, UserJobName>(
        QueueName.USER
    );

    const addNotifyUserJob = (
        data: AddNotifyUserJobData,
        opts: JobOptions = jobOptionsPreset.HIGH_RELIABILITY_SHORT_RETENTION
    ) => {
        return _addUserJob(UserJobName.NOTIFY_USER, data, opts);
    };
        ...
});

export class UserJobProducer ... {
    static readonly Live = Layer.scoped(this, make).pipe(Layer.provide(BullMqQueueService.Live));
}