骆驼码头：超过缓冲能力

Question

我使用以下路线：

<route>
    <from uri="file:...
    <setHeader headerName="CamelHttpMethod">
          <constant>PUT</constant>
    </setHeader>
    <to uri="jetty:http://localhost:55556/extract?restletMethod=PUT"/>
    <to uri="ejb:java:global/Abc/Bean?method=doSomething(${body}, ${headers})"/>
</route>

endpoint：

 public InputStream extract(@Body InputStream inputStream, @Headers Map<String, Object> headers) throws Exception {

    byte[] b = IOUtils.toByteArray(inputStream);

    // do some stuff

    headers.put("extraction", ...);

    return new ByteArrayInputStream(b);
}

如果文件大小超过2 MB，则会发生以下异常：（Camel-Jetty超文本传输协议代理大响应数据原因问题：超出缓冲容量）

JettyClient failed cause by: Buffering capacity exceeded. Exchange[ID-debianjk-scsynergy-local-43219-1479191420664-41-8]. Caused by: [java.lang.IllegalArgumentException - Buffering capacity exceeded]
        at org.apache.camel.component.jetty9.JettyContentExchange9.doTaskCompleted(JettyContentExchange9.java:156)
        at org.apache.camel.component.jetty9.JettyContentExchange9$2.onComplete(JettyContentExchange9.java:222)
        at org.eclipse.jetty.client.ResponseNotifier.notifyComplete(ResponseNotifier.java:193)
        at org.eclipse.jetty.client.ResponseNotifier.notifyComplete(ResponseNotifier.java:185)
        at org.eclipse.jetty.client.HttpReceiver.terminateResponse(HttpReceiver.java:453)
        at org.eclipse.jetty.client.HttpReceiver.terminateResponse(HttpReceiver.java:434)
        at org.eclipse.jetty.client.HttpReceiver.responseContent(HttpReceiver.java:360)
        at org.eclipse.jetty.client.http.HttpReceiverOverHTTP.content(HttpReceiverOverHTTP.java:254)
        at org.eclipse.jetty.client.http.HttpReceiverOverHTTP.content(HttpReceiverOverHTTP.java:38)
        at org.eclipse.jetty.http.HttpParser.parseContent(HttpParser.java:1472)
        at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:1245)
        at org.eclipse.jetty.client.http.HttpReceiverOverHTTP.parse(HttpReceiverOverHTTP.java:156)
        at org.eclipse.jetty.client.http.HttpReceiverOverHTTP.process(HttpReceiverOverHTTP.java:117)
        at org.eclipse.jetty.client.http.HttpReceiverOverHTTP.receive(HttpReceiverOverHTTP.java:69)
        at org.eclipse.jetty.client.http.HttpChannelOverHTTP.receive(HttpChannelOverHTTP.java:89)
        at org.eclipse.jetty.client.http.HttpConnectionOverHTTP.onFillable(HttpConnectionOverHTTP.java:123)
        at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:544)
        at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635)
        at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: Buffering capacity exceeded
        at org.eclipse.jetty.client.util.BufferingResponseListener.onContent(BufferingResponseListener.java:114)
        at org.eclipse.jetty.client.api.Response$Listener$Adapter.onContent(Response.java:245)
        at org.eclipse.jetty.client.ResponseNotifier.notifyContent(ResponseNotifier.java:124)
        at org.eclipse.jetty.client.ResponseNotifier.access$100(ResponseNotifier.java:35)
        at org.eclipse.jetty.client.ResponseNotifier$ContentCallback.process(ResponseNotifier.java:274)
        at org.eclipse.jetty.util.IteratingCallback.processing(IteratingCallback.java:246)
        at org.eclipse.jetty.util.IteratingCallback.iterate(IteratingCallback.java:208)
        at org.eclipse.jetty.client.ResponseNotifier.notifyContent(ResponseNotifier.java:117)
        at org.eclipse.jetty.client.HttpReceiver.responseContent(HttpReceiver.java:322)
        ... 13 more

问题：

有没有办法避免这种缓冲问题？（可能使用另一个组件代替jetty？）

由于码头endpoint中的主体没有改变，我想知道是否有可能将主体直接“绕过”到下一个endpoint。

Answer 1

使用<代码>