small example of how to use mikroorm's CreateRequestContext decorator with queues in NestJS

mikroorm-service-request-context.ts

@Injectable()
@Processor('processor')
export class Processor {
  constructor(
    private readonly service: Service,
    // this is needed for the CreateRequestContext decorators
    private readonly orm: MikroORM,
    private entityManager: EntityManager,
  ) {}

  @CreateRequestContext()
  private doSomethingOnTheDatabase(id: string) {
    return this.service.findSomethingFromDatabase(id);
  }

  @Process()
  async generate(job: Job) {
    await this.doSomethingOnTheDatabase(job.data.resourceId);

    return {};
  }
}