Como lidar com valores de chave de roteamento de vinculação desconhecida / inválida no RabbitMQ?

permanecerá dentro da bolsa,

Não; as trocas não "retêm" mensagens, são simplesmente roteadores.

Mensagens que não podem ser roteadas são descartadas por padrão.

Você pode configurar a ligação para retornar mensagens que não podem ser roteadas.

Consulte Canais de erro .

Os retornos são assíncronos.

Na próxima versão 3.1, você pode esperar em um futuro para determinar se a mensagem foi enviada com sucesso ou não. Consulte as confirmações do editor .

Se a mensagem não puder ser roteada, a returnedMessagepropriedade dos dados de correlação será definida.

A estrutura usa o mandatoryrecurso mencionado em outra resposta.

EDITAR

Aqui está um exemplo:

spring.rabbitmq.publisher-returns: true

spring.cloud.stream.bindings.output.destination: my-exchange
spring.cloud.stream.rabbit.bindings.output.producer.routing-key-expression: headers['rk']

spring.cloud.stream.bindings.output.producer.error-channel-enabled: true

@SpringBootApplication
@EnableBinding(Source.class)
public class So65134452Application {

    public static void main(String[] args) {
        SpringApplication.run(So65134452Application.class, args);
    }

    @Bean
    public ApplicationRunner runner(MessageChannel output) {
        return args -> {
            output.send(MessageBuilder.withPayload("foo")
                    .setHeader("rk", "invalid")
                    .build());
        };
    }

    @Autowired
    RabbitTemplate template;

    @Bean
    public Queue unroutable() {
        return new Queue("unroutable.messages");
    }

    @ServiceActivator(inputChannel = "errorChannel")
    public void error(Message<?> error) {
        if (error.getPayload() instanceof ReturnedAmqpMessageException) {
            this.template.send(unroutable().getName(),
                    ((ReturnedAmqpMessageException) error.getPayload()).getAmqpMessage());
        }
    }

}