0

我正在尝试在 Apache Camel 中将 Jetty 延续与 AsyncProcessor 一起使用,并且不得不遇到问题。基本上,我希望 Jetty Web 请求等到多播/聚合路由完成,然后用结果填充 servletResponse。所以我的骆驼路线文件如下,

    <route>
        <from ref="incomingJettyEndpoint"/>
        <inOnly uri="direct:multiCastRoute"/>
                    <process ref="asyncProcessor"/> 
    </route>
            <route>
                    <!-- Aggregator -->
            </route>

我在试图用来发回响应的交换标头中传递延续对象。谁能帮助我使用 asyncProcessor 以便线程在那里等待并且不完成继续?另外,我可以在返回所有多播消息后从聚合器通知 asyncProcessor 以便我可以写回结果吗?

4

1 回答 1

1

inOnly您的路线上意味着它不处理响应。

只是使用to,比如

<route>
    <from ref="incomingJettyEndpoint"/>
    <to uri="direct:multiCastRoute"/>
    <process ref="asyncProcessor"/> 
</route>
<route>
    <!-- Aggregator -->
</route>
于 2012-07-27T22:04:44.057 回答