link spring hornetq 集成通道

Question

这看起来很简单，但我做不出来。

我正在使用 spring-boot 1.2.2。我在 application.properties:

中设置了大黄蜂队列

spring.hornetq.mode=embedded
spring.hornetq.embedded.enabled=true
spring.hornetq.embedded.queues=myQueue

我已经导入了 integration-context.xml 文件。

@ImportResource("integration-context.xml")

并定义了以下激活器：

<int:service-activator 
    input-channel="myQueue"
    ref="myEndpointImpl"
    method="send" > 
</int:service-activator>

但是当我在 myQueue 上放置一条消息时，send 方法没有被触发。

我做错了什么？

Answer 1

HornetQ 是 JMS Broker 并且具有该配置，您只需提供具有一个 myQueue 定义的嵌入式模式，该定义由 Boot 在应用程序启动时创建。在 Spring 引导 Manual 中查看更多信息。

Spring 集成允许通过适当的 adapters.

使用 JMS

因此，如果您打算使用 Spring 集成收听 HornetQ myQueue 并进行一些进一步的集成流程，您确实应该为该队列配置 <int-jms:message-driven-channel-adapter> 并继续你的 <service-activator> 等等

欢迎提出更多问题。