通过 .handle() 为服务激活器配置输出通道

Question

已编辑 我是 Spring 集成的新手，我正在尝试将数据从服务激活器（通过句柄方法）传递到通道。

@Bean
public IntegrationFlow processFileFlow() {
    return IntegrationFlows
            .from("fileInputChannel")
            .transform(fileToStringTransformer())
            .handle("fileProcessor", "process")
            .channel("xmlChannel")
            .get();
}

@Bean
public DirectChannel fileInputChannel(){
    return new DirectChannel();
}

@Bean
public DirectChannel xmlChannel(){
    return new DirectChannel();
}

@Bean
public FileProcessor fileProcessor() {
    return new FileProcessor();
}

@Bean
public IntegrationFlow enrichDataFlow() {
    return IntegrationFlows
            .from("xmlChannel")
            .handle("enricher", "enrichProduct")
            .channel("bvChannel")
            .get();
}

@Bean
public Enricher enricher() {
    return new Enricher();
}

这是 FileProcessor 类

public class FileProcessor {

    @ServiceActivator(outputChannel = "xmlChannel")
    public String process(Message<String> msg) {
        String content = msg.getPayload();
        return content;
    }
}

这是 Enricher 类： 公共类丰富者{

    public void enrichProduct(Message<String> msg) {
        System.out.println("Enriching product " + msg);
    }
}

“正在丰富产品..”的消息没有打印出来，我不太确定出了什么问题。

Answer 1

.channel("xmlChannel") 不适合你吗？

这绝对是编写 IntegrationFlow 的正确方法 - 从一个端点通过消息通道到另一个端点。

我会说@ServiceActivator 中的outputChannel = "xmlChannel" 不会工作，因为没有inputChannel。更多 .handle() 将忽略所有这些属性，只会直接处理 fileProcessor.process() 方法。