java - 线程中的 Camel http4 路由超时

Question

我想使用 http4 路由，但让它在超时的线程内执行。我已经设置了 http4 路由，如下所示:

from("direct:start")
.setHeader(Exchange.HTTP_QUERY,simple("format=json&count=${in.headers.count}"))
.to("http4://www.host.com/someapi")
.unmarshal().json(JsonLibrary.JACKSON,MyResponseType.class)
.to("bean:SomeBean?method=echo");

我想在 http 调用周围应用 100 毫秒超时，并在这种情况下路由到故障处理程序。有谁知道如何做到这一点？

Answer 1

您可以通过指定 http4://foo?httpClient.soTimeout=100 在客户端上设置 100 毫秒的超时。当发生超时时，它可能会抛出一个异常，您可以像这样处理(我想不到，未经测试的代码):

onException(IOException.class).to("direct:timeouts");

from("direct:start")
.setHeader(Exchange.HTTP_QUERY,simple("format=json&count=${in.headers.count}"))
.to("http4://www.host.com/someapi?httpClient.soTimeout=100")
.unmarshal().json(JsonLibrary.JACKSON,MyResponseType.class)
.to("bean:SomeBean?method=echo");

from("direct:timeouts").to("...");