有没有办法使用 Spring 云流创建 RabbitMQ 队列,而无需队列的使用者。
我们的方案是,我们希望使用延迟消息传递策略,因此进入第一个队列的消息将被保留,直到过期并移动到 DLQ。 应用程序将使用来自 DLQ 的消息。
想检查是否有办法使用Spring Cloud Stream来配置队列,当我们没有第一个队列的消费者并且它只是在那里保存消息直到到期时。
是的;只需添加一个Queue
bean(如果需要,还可以绑定)。
引导自动配置一个RabbitAdmin
,该将在首次建立连接时检测此类 bean。
https://docs.spring.io/spring-amqp/docs/current/reference/html/#broker-configuration
@Bean
public Queue queue() {
return QueueBuilder.nonDurable("foo")
.autoDelete()
.exclusive()
.withArgument("foo", "bar")
.build();
}