Контейнер вызывает метод @RabbitListener и в режиме AUTO сам подтверждает сообщение (ack) после успешного выхода из метода, а при исключении — nack (по умолчанию с возвратом в очередь). Prefetch — сколько неподтверждённых сообщений получает каждый потребитель.
sottodefault-requeue-rejected=false или AmqpRejectAndDontRequeueException → DLXА ещё MANUAL ack — channel.basicAck в коде, когда обработка асинхронная
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Режимы подтверждения (acknowledge-mode):
Channel.basicAck/basicNack;Ядовитые сообщения. Если ошибка постоянная (невалидные данные), requeue=true даёт бесконечный цикл с загрузкой CPU. Решения:
spring.rabbitmq.listener.simple.default-requeue-rejected=false — отвергнутые не возвращаются, а уходят в DLX, если она настроена на очереди (x-dead-letter-exchange);AmqpRejectAndDontRequeueException для постоянных ошибок;listener.simple.retry.enabled=true, max-attempts, initial-interval, multiplier — повторы в потребителе с отсрочкой, а после — recoverer (по умолчанию reject → DLX).Prefetch (listener.simple.prefetch, по умолчанию 250) — лимит неподтверждённых у потребителя. Большой — высокая пропускная способность для быстрых задач; для долгих задач один потребитель заберёт много сообщений и будет их долго держать, пока другие простаивают, — ставят 1–10.
Параллелизм: concurrency / max-concurrency — число потребителей в контейнере.
Один верный вариант. Подумайте, потом откройте ответ.
RabbitTemplate, @RabbitListener, exchanges, bindings, manual ack, retries, DLQ и prefetch.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.