import { WorkerOptions, QueueOptions, Worker, Queue } from 'bullmq';
import { F as Factory } from '../../core-BRuvL6hY.js';
import { R as RpcCtx, a as RpcServerOptions } from '../../types-B6aU8oT-.js';
import 'phecda-core';
import '../../meta-C_eDyXnK.js';

interface BullmqCtx extends RpcCtx {
    type: 'bullmq';
}
type BullmqOptions = Omit<RpcServerOptions, 'globalAddons'> & {
    workerOpts?: WorkerOptions;
    queueOpts?: QueueOptions;
};
declare function create({ moduleMap, meta }: Awaited<ReturnType<typeof Factory>>, opts?: BullmqOptions): Promise<{
    workerMap: Record<string, Worker<any, any, string>>;
    queueMap: Record<string, Queue<any, any, string, any, any, string>>;
}>;

export { type BullmqCtx, type BullmqOptions, create };