问Spring拆分器/聚合器处理异常

EN

<task:executor id="taskExecutor" pool-size="${pool.size}"
               queue-capacity="${queue.capacity}" 
       rejection-policy="CALLER_RUNS" keep-alive="120"/>

<int:channel id="service-requests"/>
<int:channel id="service-request"/>
<int:channel id="channel-1">
    <int:dispatcher task-executor="taskExecutor" failover="false"/>
</int:channel>
<int:channel id="channel-2">
    <int:dispatcher task-executor="taskExecutor" failover="false"/>
</int:channel>


<int:gateway id="myServiceRequestor" default-reply-timeout="${reply.timeout}"
             default-reply-channel="service-aggregated-reply"
             default-request-channel="service-request"
             service-interface="com.blah.blah.MyServiceRequestor"/>

<int:splitter input-channel="service-request"
              ref="serviceSplitter" output-channel="service-requests"/>

<!-- To split the request and return a java.util.Collection of Type1 and Type2 -->
<bean id="serviceSplitter" class="com.blah.blah.ServiceSplitter"/>


<int:payload-type-router input-channel="service-requests" resolution-required="true">
    <int:mapping
            type="com.blah.blah.Type1"
            channel="channel-1"/>
    <int:mapping
            type="com.blah.blah.Type2"
            channel="channel-2"/>
</int:payload-type-router>

<!-- myService is a bean where processType1 & processType2 method is there to process the payload -->
<int:service-activator input-channel="channel-1"
                       method="processType1" output-channel="service-reply" requires-reply="true"
                       ref="myService"/>

<int:service-activator input-channel="channel-2"
                       method="processType2" output-channel="service-reply" requires-reply="true"
                       ref="myService"/>

<int:publish-subscribe-channel id="service-reply" task-executor="taskExecutor"/>

<!-- myServiceAggregator has a aggregate method which takes a Collection as argument(aggregated response from myService) -->
<int:aggregator input-channel="service-reply"
                method="aggregate" ref="myServiceAggregator"
                output-channel="service-aggregated-reply"
                send-partial-result-on-expiry="false"
                message-store="myResultMessageStore"
                expire-groups-upon-completion="true"/>

<bean id="myResultMessageStore" class="org.springframework.integration.store.SimpleMessageStore" />

<bean id="myResultMessageStoreReaper" class="org.springframework.integration.store.MessageGroupStoreReaper">
    <property name="messageGroupStore" ref="myResultMessageStore" />
    <property name="timeout" value="2000" />
</bean>

<task:scheduled-tasks>
    <task:scheduled ref="myResultMessageStoreReaper" method="run" fixed-rate="10000" />
</task:scheduled-tasks>

public void execute(final Runnable task) {
    this.executor.execute(new Runnable() {
        public void run() {
            try {
                task.run();
            }
            catch (Throwable t) {
                errorHandler.handleError(t);   /// This is the part which sends the message in to error channel.
            }
        }
    });
}

public final void handleError(Throwable t) {
    MessageChannel errorChannel = this.resolveErrorChannel(t);
    boolean sent = false;
    if (errorChannel != null) {
        try {
            if (this.sendTimeout >= 0) {
                sent = errorChannel.send(new ErrorMessage(t), this.sendTimeout);
.....