Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.twenty.com/llms.txt

Use this file to discover all available pages before exploring further.

Очереди позволяют выполнять асинхронные операции. Их можно использовать для выполнения фоновых задач, таких как отправка приветственного письма при регистрации. Каждый случай использования будет иметь собственный класс очереди, расширенный из MessageQueueServiceBase. В настоящее время мы поддерживаем только bull-mqbull-mq в качестве драйвера очереди.

​
Шаги для создания и использования новой очереди

  1. Добавьте имя очереди для вашей новой очереди в перечисление MESSAGE_QUEUES.
  2. Предоставьте фабричную реализацию очереди с именем очереди в качестве токена зависимости.
  3. Инжектируйте созданную вами очередь в необходимый модуль/сервис с именем очереди в качестве токена зависимости.
  4. Добавьте класс worker с внедрением зависимостей на основе токена, как у producer.

​
Пример использования

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
    });
  }
}