Function Processor

packages/bullmq/src/decorator.ts:16–37

(
  queueName: string,
  jobOptions?: JobsOptions,
  workerOptions?: Partial<WorkerOptions>,
  queueOptions?: Partial<QueueOptions>
)

import { QueueOptions, WorkerOptions, JobsOptions } from 'bullmq';

export function Processor(
  queueName: string,
  jobOptions?: JobsOptions,
  workerOptions?: Partial<WorkerOptions>,
  queueOptions?: Partial<QueueOptions>
): ClassDecorator {
  return function (target: any) {
    DecoratorManager.saveModule(BULLMQ_PROCESSOR_KEY, target);
    MetadataManager.defineMetadata(
      BULLMQ_PROCESSOR_KEY,
      {
        queueName,
        jobOptions,
        workerOptions,
        queueOptions,
      },
      target
    );
    Provide()(target);
    Scope(ScopeEnum.Request)(target);
  };
}

export function InjectQueue(queueName: string): PropertyDecorator {
  return DecoratorManager.createCustomPropertyDecorator(BULLMQ_QUEUE_KEY, {