骆驼交换通过码头延续到期

Question

在Apache Camel中是否有可能注册一个处理程序来管理由于已达到延续超时而无法写入jettyendpointhttp响应的交换？

Answer 1

不，这是不可能的。如果有一些处理速度较慢的交换，可能需要设置更高的超时。

欢迎您深入了解Jetty API，看看您是否可以为这样的onTimeout事件找到一个钩子，并看看在camel-jetty中需要什么来支持它。

Answer 2

我只想添加我的注释，因为我在我的项目中通过如下方式修改if（continuation.isExpired（））块中的CamelContinuationServlet使其可用

if (continuation.isExpired()) {
  String id = (String) continuation.getAttribute(EXCHANGE_ATTRIBUTE_ID);
  // remember this id as expired
  expiredExchanges.put(id, id);
  log.warn("Continuation expired of exchangeId: {}", id);

  consumer.getBinding().doWriteExceptionResponse(new TimeoutException(), response);

  return;
}

结合我的代码中名为ErrorHandlingHttpBinding的定制HttpBinding，如下所示

public class ErrorHandlingHttpBinding extends DefaultHttpBinding {

  @Override
  public void doWriteExceptionResponse(Throwable exception, HttpServletResponse response) throws IOException {
    if (exception instanceof TimeoutException) {
        response.setStatus(HttpServletResponse.SC_GATEWAY_TIMEOUT);
        response.getWriter().write("Continuation timed out...");            
    } else {
      super.doWriteExceptionResponse(exception, response);
    }
  }
}

注册为spring bean，并在组件字符串中称为jetty：http://localhost:21010/?useContinuation=true