我正在使用春云流与rabbitMQ。我试图通过删除运行时的队列并将消息发送到已删除的队列来进行负面测试。
source.queue2Source().send(MessageBuilder.withPayload(queue4DTO).build());我正在监听队列1中的消息,并将消息发送到队列2(已删除的消息)。我原以为上面的代码会抛出一个异常,但事实并非如此。甚至从队列1读取的消息也已被确认。队列1和队列2上有一个死信队列,但是消息没有进入dlq。
发布于 2018-07-05 12:09:49
这是因为您要向由channel定义的Source发送消息。该通道确实存在,并通过AMQPOutboundChannelAdapter连接到一个交换,在默认情况下,该交换将丢弃不可交付的消息。
https://stackoverflow.com/questions/51187228
复制相似问题