Camel Restを使用しているときにリクエストペイロードを記録する方法は？

Question

Camel Restエンドポイントを使用しているときに元の「生の」リクエストボディ（JSONなど）を記録したいとします。これを行う適切な方法は何ですか？

マイセットアップ（RouteBuilder）は次のようになります。ここ

restConfiguration().component("jetty") 
    .host(this.host) 
    .port(this.port) 
    .contextPath(this.contextPath) 
    .bindingMode(RestBindingMode.json); 

rest("myService/").post() 
    .produces("application/json; charset=UTF-8") 
    .type(MyServiceRequest.class) 
    .outType(MyServiceResponse.class) 
    .to(SERVICE_CONTEXT_IN); 

from(SERVICE_CONTEXT_IN).process(this.serviceProcessor); 

私の問題は、いずれかのプロセッサは、そのような取引の性質として要求を保存するようメカニックは、このアプローチを使用したという点で「遅すぎる」ということですルートで遅すぎます。つまり、バインドが既に行われ、リクエストを消費しました。 CamelHttpServletRequestのInputStreamもすでに読み込まれており、データは含まれていません。

ログEIPを使用する最初の場所は、シングルプロセッサの直前にある：

from(SERVICE_CONTEXT_IN).log(LoggingLevel.INFO, "Request: ${in.body}") 
    .process(this.serviceProcessor); 

が、その時点で${in.body}既にMyServiceRequestのインスタンスです。上のログを追加すると、単純にRequest: x.y.z.MyServiceRequest@12345678が得られます。私が記録したいのは、オリジナルのJSONをPOJOにバインドする前です。

RestConfigurationDefinitionやRestDefinitionで 'raw'リクエストのログを有効にする組み込みの方法はないようです。

私は自動JSONバインディングを取り除き、HTTP Post要求のInputStreamを手動で読み込み、専用のプロセッサで手動で非整列化などを実行できますが、ビルトインバインディングを保持したいと思います。

Answer 1

：

restConfiguration().component("jetty") 
    .host(this.host) 
    .port(this.port) 
    .contextPath(this.contextPath); 

rest("myService/").post() 
    .produces("application/json; charset=UTF-8") 
    .to(SERVICE_CONTEXT_IN); 

from(SERVICE_CONTEXT_IN).process(this.requestLogProcessor) 
    .unmarshal() 
    .json(JsonLibrary.Jackson, MyServiceRequest.class) 
    .process(this.serviceProcessor) 
    .marshal() 
    .json(JsonLibrary.Jackson); 

すべてrequestLogProcessorInputStreamとしてin体を読み取ることがされていStringを取得してログに記録し、最終的に渡します。

Answer 2

キャメルレストのエンドポイントを使用して、生のリクエストをログに記録する方法がないことに同意します。

しかし、考慮にRoman Vottnerを取って、次のように、あなたはあなたのrestConfiguration()を変更することがあります。

restConfiguration().component("jetty") 
    .host(this.host) 
    .port(this.port) 
    .componentProperty("handlers", "#yourLoggingHandler") 
    .contextPath(this.contextPath) 
    .bindingMode(RestBindingMode.json); 

あなた #yourLoggingHandlerニーズがあなたのレジストリに登録する

とorg.eclipse.jetty.server.Handlerを実装します。 Jettyのマニュアルhttp://www.eclipse.org/jetty/documentation/current/jetty-handlers.html#writing-custom-handlersでカスタムハンドラを記述してください。私はペイロードを記録するために高度に洗練されたプロセッサと結合REST DSLを使用していないことにより、この「解決」末端で