Apache Camel：如何通过SEDAendpoint传输异常？

Question

private final String internalRespUri = "direct:internal_resp";
private final String internalRespTimeout = "seda:internaltimeout";

@Override
public void configure() {
    SendController send_controller = new SendController();
    TimeoutResponse resp = new TimeoutResponse();

    from(Endpoints.MESSAGE_IN.direct())
                    .errorHandler(noErrorHandler())
                    .routeId(Endpoints.MESSAGE_IN.atsm())
                    .log("Incoming message at segment in")
                    .process(send_controller)
                    .log("Message after send controller")
                    .multicast().parallelProcessing()
                    .log("After wiretap")
                    .to(internalRespTimeout, Endpoints.SEGMENT_OUT.direct());
    from(internalRespTimeout)
                    .errorHandler(noErrorHandler())
                    .routeId(internalRespTimeout)
                    .log("begin response route")
                    .log("timeout response route")
                    .process(resp)
                    .log("modify message to response")
                    .delay(1000)
                    .log("after delay")
                    .to(internalRespUri);
    from(Endpoints.SEGMENT_IN.seda())
                    .routeId(Endpoints.SEGMENT_IN.atsm())
                    .to(internalRespUri);
    from(internalRespUri)
                    .errorHandler(noErrorHandler())
                    .routeId(internalRespUri)
                    .log("after response gathering point")
                    .choice()
                    .when(header(HeaderKeys.TYPE.key()).isEqualTo(UserMessageType.RESP.toString()))
                    .log("process responses")
                    .process(send_controller)
                    .otherwise()
                    .log("no response")
                    .to(Endpoints.MESSAGE_OUT.direct());
}

Answer 1

我有个主意：

我可能会使用事务来超时，而不是引发异常。

这能行吗？