Queue yapısını incelemenizi tavsiye ederim. İşlemleri kuyruğa ekleyerek ister tekli, ister çoklu şekilde tüketebilirsiniz. Kaba tabirle işlemleri sırasıyla DB'ye eklenir (redis vb.) listeners tarafından dinlenerek işlemler arka tarafta tamamlanır.
Bu mantığı kullanıyoruz zaten yapımızda.
Fakat yine'de eksik alıyor mesajları tamamını anında almıyor.
Saygılarımla.