Mesaj Kuyruğu

Kuyruklar, asenkron işlemlerin gerçekleştirilmesine imkan tanır. Kayıt esnasında hoş geldin e-postası göndermek gibi arka plan görevleri gerçekleştirmek için kullanılabilirler. Her kullanım durumu, MessageQueueServiceBase’den genişletilmiş kendi kuyruk sınıfına sahip olacaktır. Şu anda yalnızca kuyruk sürücüsü olarak bull-mqbull-mq destekliyoruz.

Yeni bir kuyruk oluşturma ve kullanma adımları

Yeni kuyruğunuz için enum MESSAGE_QUEUES altında bir kuyruk adı ekleyin.
Kuyruğun değişken adını bağımlılık belirteci olarak kullanarak kuyruk fabrikası uygulamasını sağlayın.
Oluşturduğunuz kuyruğu, gerekli modüle/hizmete kuyruk adıyla birlikte bağımlılık belirteci kullanarak enjekte edin.
Üretici gibi token tabanlı enjeksiyon ile çalışan sınıfını ekleyin.

Örnek kullanım

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

Yeni bir kuyruk oluşturma ve kullanma adımları

Örnek kullanım

​Yeni bir kuyruk oluşturma ve kullanma adımları

​Örnek kullanım

Yeni bir kuyruk oluşturma ve kullanma adımları

Örnek kullanım