我想使用消息驱动通道适配器以编程方式处理消息 . 这是我必须实现的场景:我在启动期间的应用程序从服务中读取配置 . 配置提供有关将包含消息的队列的信息 . 因此,我想为每个队列创建一个消息驱动通道适配器,以异步侦听消息 .
以编程方式而不是使用XML初始化所有spring集成上下文的任何示例都将是有用的 .
如果您打算以编程方式执行所有操作,我建议您绕过Spring Integration魔术并直接使用 DefaultMessageListenerContainer .
DefaultMessageListenerContainer
之后,您可以直接从 MessageListener 实现或使用Messaging Gateway将消息发送到现有的 MessageChannel .
MessageListener
MessageChannel
请注意编程配置,不要错过重要的属性,如 ApplicationContext 或 afterPropertiesSet() 的调用 .
ApplicationContext
afterPropertiesSet()
1 回答
如果您打算以编程方式执行所有操作,我建议您绕过Spring Integration魔术并直接使用
DefaultMessageListenerContainer
.之后,您可以直接从
MessageListener
实现或使用Messaging Gateway将消息发送到现有的MessageChannel
.请注意编程配置,不要错过重要的属性,如
ApplicationContext
或afterPropertiesSet()
的调用 .