java - 如何将 ConnectionFactory 类设置为 Jms outboundAdapter？ (在 Spring 集成中)

Question

我正在使用 Spring Integration，并且我正在尝试(在 IntegrationFlow 中)在 Jms 中使用 connectionFactory 设置 outboundAdapter。由于我是这些类的新手，因此我无法创建任何不会在该代码片段中引发错误的内容。如何定义 ConnectionFactory 类才能使其正常工作？

private MessageChannel workflowExample() {
    return IntegrationFlows
            .from(requests())
            .transform(someTransformer())
            .handle(Jms.outboundAdapter(connectionFactory)
                   .destination("somewhere"))
            .get();
}

Answer 1

您需要了解您将使用什么 JMS 客户端。如果是 ActiveMQ，则ConnectionFactory可能是这样的:

ConnectionFactory amqFactory = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false")

这就是我们在嵌入式模式下进行测试的方法。

如果您的 JMS 代理由 JEE 服务器管理，那么您需要找出 ConnectionFactory 的 JNDI 名称。对象并使用 Spring JNDI 支持来获取它。

如果您使用 IBM MQ，那么您需要使用他们的 JMS 包装器才能实例化 ConnectionFactory适本地。等等。有一个 Tibco JMS 客户端、一些 Rabbit MQ 的 JMS 包装器等。

无论如何ConnectionFactory实例化不是 Spring Integration 的责任。您确实需要弄清楚您使用的 JMS 客户端并遵循其文档如何创建。 Spring JMS 支持可以帮助您处理一些样板代码和依赖项管理:https://docs.spring.io/spring/docs/5.2.3.RELEASE/spring-framework-reference/integration.html#remoting-jms

您还可以查看配置文件支持，以便您可以在本地针对嵌入式 ActiveMQ 测试您的流程并在生产中连接到外部代理:https://docs.spring.io/spring/docs/5.2.3.RELEASE/spring-framework-reference/core.html#beans-definition-profiles