Fila de Mensagens

Filas facilitam operações assíncronas a serem realizadas. Elas podem ser usadas para realizar tarefas em segundo plano, como enviar um email de boas-vindas ao se registrar. Cada caso de uso terá sua própria classe de fila estendida de MessageQueueServiceBase. Atualmente, só damos suporte ao bull-mqbull-mq como o driver de fila.

Passos para criar e usar uma nova fila

Adicione um nome de fila para sua nova fila no enum MESSAGE_QUEUES.
Forneça a implementação da fábrica da fila com o nome da fila como o token de dependência.
Injete a fila que você criou no módulo/serviço necessário com o nome da fila como o token de dependência.
Adicione uma classe de trabalhador com injeção baseada em token, assim como o produtor.

Exemplo de uso

class Resolver {
  constructor(@Inject(MESSAGE_QUEUES.custom) private queue: MessageQueueService) {}

  async onSomeAction() {
    //business logic
    await this.queue.add(someData);
  }
}

//async worker
class CustomWorker {
  constructor(@Inject(MESSAGE_QUEUES.custom) private queue: MessageQueueService) {
    this.initWorker();
  }

  async initWorker() {
    await this.queue.work(async ({ id, data }) => {
      //worker logic
    });
  }
}

Welcome

Core Concepts

Passos para criar e usar uma nova fila

Exemplo de uso

​Passos para criar e usar uma nova fila

​Exemplo de uso

Passos para criar e usar uma nova fila

Exemplo de uso