如何使用 Spring XDRabbit 源自动创建 rabbitmq 队列

Question

我的流定义中有 Spring XD Rabbit 源，但是当它正在侦听的队列尚未创建时它会失败。当我使用 Spring Integration Boot 时，我可以在我的 JavaConfig 中执行此操作。

我的流定义： 流创建 --name HOLA_Q --definition "rabbit --requeue=false | my-own-processor | null" --deploy

我尝试在我自己的处理器中的 spring-module.xml 中使用 rabbit admin，但在流部署期间不起作用或被触发。

或者这个兔子队列自动创建功能还不支持？

非常感谢

Answer 1

目前不支持源自动创建队列。

根据文档：

在部署流之前，队列必须存在。我们不会自动创建队列。但是，您可以使用 RabbitMQ Web UI 轻松创建队列。然后，使用相同的 UI，您可以导航到“rabbittest”队列并向其发布测试消息。

您可以创建一个自定义 rabbit 源，将队列（以及可选的交换和绑定）以及 RabbitAdmin bean 添加到应用程序上下文中，并且将声明队列/交换/绑定。