doSend
BlokingQueueConsumer
Throw Exception
RetryExhausted
RabbitMQ Broker Normal Queue
always ack to consumer queue whether the message delivery to DLQ success or not
nack and throw exception
send message to DLQ
handle failed
RabbitMessageChannelBinder
Delivered to DLQ?
Enable publishconfirmspring.rabbitmq.publisher-confirm-type = correlated
no
RabbitMQ Broker DLQ
nack + requeue: false - Rabbit will mark message as Dead letter messagex-dead-letter-exchange:XXX.DLXx-dead-letter-routing-key:XXX
yes
ack
AbstractMessageChannel
mainloop() - Message received from queue
App consumer API
AmqpInboundChannelAdapter
sendInternal
dispatcher
commitIfNecessary-basicAck
SimpleMessageListenerContainer
rollbackOnExceptionIfNecessary-basicNack: requeue = false
handle success case
nack
BroadcastingDispatcher
