キャメル・エクスチェンジが桟橋の続きで終了しました

Question

継続タイムアウトに達したために、jettyエンドポイントのhttp応答に書き込めない交換機を管理するためのハンドラを登録する可能性はありますか？

Answer 1

これは不可能です。遅い処理交換がある場合は、より高いタイムアウトを設定する必要があるかもしれません。

このようなonTimeoutイベントのフックを見つけて、それをキャメル・ブーティーでサポートするために必要なものがあるかどうかは、Jetty APIを参照してください。

Answer 2

私はこのような私のコードでErrorHandlingHttpBindingというカスタムHttpBindingとの組み合わせで、この

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; 
} 

ようif (continuation.isExpired())ブロックでCamelContinuationServletを変更することによって、私のプロジェクトでは、それが利用可能になったので、私はちょうどその上で私のノートを追加します

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); 
    } 
    } 
} 

id="errorHandlingHttpBinding"とスプリングBeanとして登録さjetty:http://localhost:21010/?useContinuation=true&continuationTimeout=1&httpBindingRef=errorHandlingHttpBindingとして成分ストリングにいいます。