以编程方式创建消息驱动通道适配器以处理队列中的消息

Question

我想使用消息驱动通道适配器以编程方式处理消息。这是我必须实现的场景： 我的应用程序在启动期间从服务读取配置。该配置提供有关将包含消息的队列的信息。因此我想为每个队列创建一个消息驱动的通道适配器来异步监听消息。

任何以编程方式而不是使用 XML 初始化所有 spring 集成上下文的示例都是有用的。

Answer 1

如果您要以编程方式完成所有操作，我建议您绕过 Spring 集成魔法，直接使用 DefaultMessageListenerContainer。

之后，您可以直接从 MessageListener 实施或使用 Messaging Gateway 向现有 MessageChannel 发送消息。

请注意编程配置，不要遗漏 ApplicationContext 等重要属性或 afterPropertiesSet() 的调用。