Message Queue Simulasyonu

Message Queue Simulasyonu

Bu ödevde LinkedList tabanlı basit bir Message Queue sistemi implement edeceksiniz. Sistem, mesaj yayınlama (publish), kuyruktan tüketme (consume), ve başarısız mesajları Dead Letter Queue'ya taşıma gibi temel messaging kavramlarını simüle eder.

Gereksinimler

Message sınıfı:

• id (String) — Benzersiz mesaj ID
• body (String) — Mesaj içeriği
• retryCount (int) — Kaç kez denendiği (varsayılan: 0)

SimpleMessageQueue sınıfı:

1. void publish(String id, String body) — Yeni mesajı kuyruğa ekler (FIFO sırası).
2. Message consume() — Kuyruktan bir mesaj alır (poll). Kuyruk boşsa null döner.
3. void nack(Message msg, int maxRetries) — Mesajı kuyruğun sonuna tekrar ekler ve retryCount'u artırır. Eğer retryCount >= maxRetries ise mesajı Dead Letter Queue'ya (DLQ) taşır.
4. Message consumeDlq() — Dead Letter Queue'dan bir mesaj alır. Boşsa null döner.
5. int queueSize() — Ana kuyruğun boyutunu döner.
6. int dlqSize() — DLQ boyutunu döner.

Girdi Formatı

Program stdin'den satır satır komutlar okur:

• PUBLISH id body — Mesaj yayınla
• CONSUME — Kuyruktan mesaj al ve yazdır
• NACK id maxRetries — Mesajı geri koy veya DLQ'ya taşı (son consume edilen mesajı kullanır)
• CONSUME_DLQ — DLQ'dan mesaj al ve yazdır
• SIZE — Ana kuyruk ve DLQ boyutlarını yazdır
• EXIT — Programı sonlandır

Çıktı

• CONSUME / CONSUME_DLQ: Mesaj varsa id:body formatında yazdır, yoksa EMPTY yazdır.
• NACK: Mesaj DLQ'ya taşındıysa DLQ:id yazdır, tekrar kuyruğa eklendiyse REQUEUED:id yazdır.
• SIZE: queue=X, dlq=Y formatında yazdır.
• Diğer komutlar çıktı üretmez.

Örnek

PUBLISH msg-1 OrderCreated
PUBLISH msg-2 PaymentReceived
CONSUME
→ msg-1:OrderCreated
NACK msg-1 3
→ REQUEUED:msg-1
SIZE
→ queue=2, dlq=0

Önemli Not

NACK komutu, en son CONSUME ile alınan mesajı işler. Program hangi mesajın consume edildiğini takip etmelidir. Eğer consume edilmiş bir mesaj yoksa veya ID eşleşmiyorsa, NACK'i göz ardı edin.