问题标签 [aggregator]

我有一个自定义聚合器，在 reduce 方法中我想使用累加器来做一些统计。

我应该如何将累加器传递给聚合器？

我必须将累加器作为构造函数参数传递还是必须使用AccumulatorContext.get(0)？

我正在尝试使用迭代器从销售人员中提取数据，最后使用聚合器整合数据。

当我尝试使用邮递员调用服务时，它显示超时错误。“无法得到任何回应”。

我所需要的只是整合来自 Iterator 的数据并将项目返回给最终用户。如果您对此有任何线索或想法，请发表评论。

pom.xml (Aggregator - setup submodules A,B,C)<br/> | project-A / pom.xml | project-B / pom.xml (Set Project A as Parent) | project-C / pom.xml (Set Project A as Parent)

当我在根 pom.xml 上触发安装时，它会抛出一个异常，即 Non-resolvable parent POM failre to find project A..​​...

明白了我们可以先手动构建A然后解决它。然而

有谁知道如何修复 pom 结构，以便我只能调用 root pom，它可以一次性构建所有项目？

我正在尝试在弹性查询中进行分组和子分组，首先按 ipgroup，然后按优先级。

但是最后一条语句给出了编译错误，指出“FilterAggregationBuilder 类型中的方法过滤器（FilterBuilder）不适用于过滤器（aggFilter）的参数（BoolQueryBuilder）”

我有一个场景，我需要并行调用 A 和 B 系统的 REST 调用并聚合响应并转换为单个FinalResponse.

为此，我使用了 Spring Integration 拆分器和聚合器，配置如下所示。

我已经公开了一个 REST 端点，当请求（请求在标头中有 co-relationId）到达控制器时，我们调用网关并且拆分器将请求发送到 A 和 B 通道。服务激活器 A 监听通道 A 并调用 A 系统的 REST 调用，服务激活器 B 监听 B 通道并调用 B 系统的 REST 调用。然后我需要汇总来自 A 和 B 系统的响应，然后将其转换为FinalResponse. 目前聚合和转换工作正常。

有时当多个请求到达控制器FinalResponse时，与对控制器的单个请求相比，需要更多时间。对请求的所有响应几乎同时出现，不知道为什么（即使对控制器的最后一个请求是在第一个请求后 6-7 秒发送的）。我的与线程相关的配置有问题吗？不知道为什么当多个请求到达控制器时需要更多时间来响应。另外，我没有使用任何 CorrelationStrategy，我们需要使用它吗？使用以下配置，我会在多线程环境中遇到任何问题吗？ 有关配置的任何反馈都会有所帮助

我的问题是：
如何在我自己的网站主页上列出另一个网站的 RSS 提要，这样，当访问者点击这些列表中的任何一个时，它会将访问者引导到我从中获取这些 RSS 提要的网站？

仅供参考：我正在使用 Wordpress。

forceCompletionOnStop 和 completeAllOnStop 有什么区别？是否可以或建议同时使用两者？

从文档中：

forceCompletionOnStop指示在上下文停止时完成所有当前聚合交换

completeAllOnStop指示在上下文停止时等待完成所有当前和部分（未决）聚合交换。这也意味着我们将等待存储在聚合存储库中的所有未决交换完成，以便在我们停止之前存储库为空。您可能希望在使用仅基于内存的基于内存的聚合存储库时启用此功能，并且不要将数据存储在磁盘上。启用此选项后，聚合器在停止 CamelContext 或使用它的路由时等待完成所有这些交换。

它对我来说有点混乱，它似乎是一样的

我想将聚合的结果作为路由的主要消息，而不是 IN 上的原始消息。我也想在一条路线上做到这一点。

我知道我可以.to("direct:one_result")在聚合之后使用，但是我在一个路由中这样做有很大的限制，因为我正在动态生成路由。

我的.to("mock:out")将被更长的路线定义所取代。

测试输出如下所示：

我正在创建一个代表购物车的 ShoppingCart 类。我对类的基础知识和 getTotalPrice 方法很了解，但我无法弄清楚如何解决 getItemIndex 问题...“完成 getItemIndex 方法如下：如果 itemList 有一个名称传递给参数的项目，返回该项目在数组中的索引。否则返回 -1。"

我知道我必须调用 Items 类，但我不明白如何从项目类中获取名称并返回索引。

我已经创建了 Items 类以及 ShoppingCart 类的实例变量和构造函数。我查看了其他购物车方法，但找不到执行 getItemIndex 的方法

我尝试了包含在底部的名为 getItemIndex 的代码...我包含了 getTotalPrice 以防需要它作为参考。

}

这是项目类

}

我期望一个方法是 if 语句，但我不确定如何获取 ItemIndex ...我也不确定这是否需要 for 循环。在另一个类中，我将调用此方法来使用它来模拟购物体验。

我必须为 addToCart 方法创建代码以将项目添加到 itemList。我在这里查看了其他 ShoppingCart 问题，但我没有看到增加商品数量并检查商品名称以查看它是否在数组中的问题...问题是

1) 如果在 itemList 中已经存在具有传入参数名称的项目，则通过将其增加传入的数量来更新该项目数量。

2) 如果 itemList 中不存在商品名称并且有空间容纳新商品，则使用作为参数传入的给定名称、数量和价格创建一个新商品对象，将 numItems 更新为 1。

3) 两种情况都应该返回 true。

4) 如果具有给定名称的项目不在数组中并且数组没有容量，则该方法应返回 false...

5）完成dispay方法打印出itemList中每件商品的名称、总价、数量

我做了一个 getItemIndex 方法，但不确定是否需要在这个方法中使用它。当我查看其他 addtoCart 方法时，我认为这个是不同的。

我尝试了一个 for 循环，但它没有返回我想要的，所以我创建了新对象，但我无法让对象保留在对象数组中。

物品类

购物车类

结果应该将项目放入数组并保留在其中，因此当我在我的 main 方法中调用它时，它将保留在数组中，并且当我调用它时它应该像这样打印

牛奶 $3.00 1 $3.00
鸡蛋 $3.00 1 $3.00

等等......这将通过我的模拟方法打印，但我无法弄清楚如何让物品留在购物车中。