apache CAMEL-SEDAendpoint组播
from("seda:start)
.multicast(new GroupedBodyAggregationStrategy())
.parallelProcessing()
.to("seda:process1", "seda:process2")
.end()
.to("seda:join");
to("seda:process1?waitForTaskToComplete=Always", "seda:process2?waitForTaskToComplete=Always")
有什么想法吗？
共有1个答案
您可以使用seda使start and join组件。而process1和process2使用multicast和paralellprocessing，这将负责并行运行这些进程。
对于seda:start，
from（“seda：start？concurrentconsumers=10”）将开始并行接受10个请求。欲了解更多信息，请查看http://camel.apache.org/seda.html
-
我正在尝试向异步路由发送消息，但它不起作用。我刚刚在github上创建了一个项目来模拟这个问题
-
我正在使用apache camel cxf开发一个Web服务（肥皂），我遇到了这个错误。 Java . lang . illegalargumentexception:Part { http://blue print . camel . ngt . TN/}返回的类型应为[ltn . ngt . camel . blue print . WB _ subscriptions；，而不是org . A
-
我从基于apache-camel-spark的rest接口获得一个json数组作为输入。开始时，我想通过apache camels路线分割json-array来处理每个元素。我该怎么做？ 我的测试输入json： 对于这个问题，我在stackoverflow上找到了一些间接描述的问题： link 1， link 2， link 3。 根据这些示例，我尝试了以下骆驼路线： 当我这样做时，我总是得到以下
-
我有一个restendpoint示例。org，返回表单的json响应 我的路线是这样的 我读过关于轮询消费者的内容，但找不到如何继续轮询endpoint的示例，直到它返回“success”响应。 是否应该使用轮询消费者？如果是这样的话，可以举一个与我的案例相关的例子。用于轮询restendpoint的任何其他资源都非常有用。
-
我试图在聚合器完成后获得一个回复，但是我得到一个异常，我没有指定任何聚合器子项，但是当我指定一个。to（）endpoint我没有收到聚合结果。。。这可能吗？ 控制器： 聚合器：
-
我正在尝试编写一条路由，将消息转发到这样的sedaendpoint 还有另一个从seda终结点消耗的路由： JMS连接工厂的JMS确认模式是CLIENT_ACKNOWLEDGE，我已经使用spring boot配置了该项目。根据配置，一旦第一个驼峰路由结束，它就应该提交事务并将确认发送给message broker。 但是，这种行为是消息确认只在第二条路由完成后发生。我可以在第一个路由中配置什么来