Spring 与 JMS 出站适配器的集成文件

Question

我正在做一个项目，我使用 spring 集成文件轮询目录中的文件到入站通道，用它做一些事情，然后使用 <int-jms:outbound-channel-adapter> 将结果发布到 MQ 但是如果不通过 xml 配置文件，我找不到任何关于如何实施此解决方案的有用示例。

不过我不确定以下示例是否是这种情况的解决方案

@Bean
public IntegrationFlow jmsOutboundGatewayFlow() {
    return IntegrationFlows.from("jmsOutboundGatewayChannel")
            .handle(Jms.outboundGateway(this.jmsConnectionFactory)
                        .replyContainer(c ->
                                    c.concurrentConsumers(3)
                                            .sessionTransacted(true))
                        .requestDestination("jmsPipelineTest"))
            .get();
}

Answer 1

网关用于request/reply处理；仅使用 Jms.outboundAdapter() 方法之一发送。

Spring 与 JMS 出站适配器的集成文件

Spring integration file with JMS outbound adapter

java

spring-jms

spring-boot

spring-integration-dsl