feat: get workers/processors

[anchan828]

Execute worker/processor manually

You can execute worker/processor manually.

@Controller("/worker")
class WorkerController {
  constructor(private readonly service: QueueWorkerService) {}

  @Post()
  public async execute(@Body() body: QueueWorkerReceivedMessage): Promise<void> {
    const workers = await this.service.getWorkers(body.message);

    for (const worker of workers) {
      const processors = worker.getProcessors();

      for (const processor of processors) {
        const result = await processor.execute();

        if (result.success) {
          console.log("Success");
        } else {
          console.log("Failed:" + result.error.message);
        }
      }
    }
  }
}

Breaking changes

• Remove Global Events: Removed __unhandled_queue_worker and __all_queue_workers
• Remove config.extraConfig: Removed preProcessor and postProcessor