Весенний облачный стрим не бросает исключение

Question

Я использую весенний облачный поток с rabbitMQ. Я пытаюсь выполнить отрицательный тест, удалив очередь во время выполнения и отправив сообщение в удаленную очередь.

source.queue2Source().send(MessageBuilder.withPayload(queue4DTO).build());

Я слушаю сообщение из очереди 1 и отправляю сообщение в очередь 2 (удалено). Я ожидал, что выше кода вызовет исключение, но это не так. Даже сообщение от чтения из очереди 1 было подтверждено. У меня есть очередь недоставленных сообщений в очереди 1 и 2, но сообщение не вошло в dlq.

Answer 1

Это потому, что вы отправляете сообщение на channel, определенный Source. Канал действительно существует и соединен через AMQPOutboundChannelAdapter с обменом, который по умолчанию отбрасывает недоставленные сообщения.