流的集成测试（Java DSL配置）

Question

我正在尝试为流配置实现一些测试。我将JMS入站通道适配器作为流的入口点，并将出站文件通道适配器（带有附加的ExpressionEvaluatingRequestHandlerAdvice）作为最后一个endpoint。

下面是一个示例代码：

@Bean
public IntegrationFlow fileProcessingFlow() {
    DefaultMessageListenerContainer dmlc = new DefaultMessageListenerContainer();
    dmlc.setConnectionFactory(connectionFactory);
    dmlc.setDestination(jmsQueue);

    return IntegrationFlows.from(Jms.messageDrivenChannelAdapter(dmlc))
        .<String, File>transform(p -> new File(p))
        .handle(headerEnricherService)
        .<Boolean>route("T(SomeEnum).INVALID.equals(headers['headerName'])", mapping -> mapping 
            .subFlowMapping(Boolean.TRUE, sf -> sf.handle(serviceRef, "handleInvalidFile"))
            .subFlowMapping(Boolean.FALSE, sf -> sf
                .handle(serviceRef, "handleValidFile")
                .handle(anotherServiceRef)))
        .filter(additionalFilterRef)
        .handle(Files.outboundAdapter("'output/dir/path'")
                     .autoCreateDirectory(true)
                     .deleteSourceFiles(true),
                c -> c.advice(fileCopyAdvice()))
        .get();
}

null

谢谢你。

Answer 1

好吧，亚历克斯，

因为你找不到任何样品，也找不到任何文章或其他东西，这意味着没有这样的东西。

仅仅因为Spring Integration没有一个固执己见的测试工具。

默认情况下，endpoint通过DirectChannel连接，其中bean名称基于以下模式:[integrationflow.beanname].channel#[channelNameIndex]。

因此，在您的示例中，jms.messagedrivenchanneladapter()之后和transform()之前的通道具有类似于fileprocessingflow.channel#0的bean名称。

不确定您对MessageHistory的担忧。您可以简单地在测试工具中再添加一个@configuration类，在其中声明@enableMessageHistory。