Function Processor

Mark a class as an eddyq job processor. The class is registered as an @Injectable() provider; at bootstrap, the module scans its methods for @JobHandler(kind) annotations and wires each one to queue.work(kind, …).

@Processor()
class EmailProcessor {
  @JobHandler("send.email")
  async send({ payload }: JobCall) { … }
}
Copy