Spring集成——用消息转换器将一个通道路由到特定的通道

Question

我是Spring集成的新手

我的目标是将信息从一个渠道传递到另一个渠道(链式过程)

通道1---

1.

    Each channel payloads will have different Class Objects.

尝试： 1.当我尝试使用@transformer无法与“erroeChannel”通信时。

问题：

找到答案

Configuration:

<int:channel id="channel1"/>
<int:channel id="channel2"/>
<int:channel id="channel3"/>
<int:channel id="channel4"/>

<int:service-activator input-channel="channel1" ref="firstChannel" method="doProcess1" />
<int:service-activator input-channel="channel2" ref="secondChannel" method="doProcess2" />
<int:service-activator input-channel="channel3" ref="thirdChannel" method="doProcess3" />
<int:service-activator input-channel="channel4" ref="forthChannel" method="doProcess4" />
<int:service-activator input-channel="errorChannel" ref="errorHandlerChannel" method="doErrorProcess" />

Java Code: 

public FirstChannel {

    private Map<String, MessageChannel> msgChannels;
    boolean isError = false;
    @Autowired
    public ScheduleParser(Map<String, MessageChannel> msgChannels) {
        super();
        this.msgChannels = msgChannels;
    }

    public void doprocess1(Message<?> message){
    File file = (File) message.getPayload();
    //business code 

    if(!isError)
        //transforming the messae
        msgChannels.get("channel2").send(new GenericMessage(EmployeeVO , headersMap));
    else 
        msgChannels.get("errorChannel").send(new GenericMessage(ObjectVO , headersMap));
}

}

其他通道代码也是如此

Answer 1

通道并不相互连接，而是连接到endpoint。

变形金刚不路由，路由器路由。

你需要像这样的东西

channel1->payload-type-router

type1Channel->...
type2Channel->...
...

可能为下游的每种有效载荷类型配备不同的变压器。

通常，展示您尝试过的配置比展示一些抽象概念更好。

错误流配置取决于启动流的内容（网关、轮询器等）-即channel1的上游。

编辑

您的配置完全错误。例如，您当前在channel1上有两个订户，一个是头值路由器，另一个是服务激活器。

到达< code>channel1的消息将交替发送到其中一个，而发送到服务激活器的消息将永远不会发送到路由器。

不知道完整的图片，我猜你需要类似...

channel1->serviceActivator1->channel1toRouter->router(channel2 or failed)
channel2->serviceActivator2->channel2toRouter->router(channel2 or failed)
...