Day 3

Message Lifecycle: Publish, Deliver, Ack, Nack, Requeue

আজকের ফোকাস হলো message success আর failure path। RabbitMQ শেখার সবচেয়ে critical জায়গাগুলোর একটি হচ্ছে acknowledgement behavior।

Message Lifecycle

Ack Strategy Table

Situation	Recommended Action	কেন
Success	`Ack`	message safe ভাবে complete
Temporary DB timeout	`Nack(requeue=true)` বা retry queue	পরে আবার চেষ্টা করা যাবে
Invalid payload	`Nack(requeue=false)` + DLQ	endless retry useless
Consumer crash before ack	RabbitMQ redelivery করতে পারে	reliability বাড়ে

Successful vs failed processing

Publish

Producer message publish করে এবং সেটা queue-তে stored বা routed হয়।


msgs, err := ch.Consume("orders.queue", "", false, false, false, false, nil)
if err != nil {
	log.Fatal(err)
}
 
for msg := range msgs {
	if err := process(msg.Body); err != nil {
		_ = msg.Nack(false, true)
		continue
	}
 
	if err := msg.Ack(false); err != nil {
		log.Printf("ack failed: %v", err)
	}
}

Auto Ack কেন production-এ risky?

Checkpoint

নিজে এই প্রশ্নের উত্তর দাও: 'ack মানে success signal, retry policy না' — কেন?

Ack শুধু current message fate finalize করে
Retry strategy application বা topology design-এর অংশ
Ack/Nack decision business error type-এর ওপর নির্ভরশীল