在这个例子中，有两条消息是由计时器发送的。第二条消息在第一条消息尚未完成时开始处理。我希望消息是一个接一个地直接处理的。Send message: 2DONE: 2 / [1, 2, 3, 4, 5]这里的问题是“聚合没有聚合的“直接”正确工作。换句话说:直接和聚合不同步(它们在不同的线程中运行)。Direct并不是在等待聚合完成
浏览 0提问于2021-08-25得票数 0
回答已采纳
我有一个用例，其中我的消息被分割了两次，我想聚合所有这些消息。如何才能最好地实现这一点，我应该通过引入不同的序列头来聚合两次消息，或者是否有一种方法可以通过重写消息分组的方法在单个聚合步骤中聚合消息？
浏览 2提问于2022-06-23得票数 0
1回答
我有一个列表，比方说10，我想使用最大值6进行聚合。在这种情况下，它应该是这样工作的:前六条消息被聚合到一条消息中，然后立即(没有任何超时)将接下来的4条消息聚合到第二条消息中。我尝试使用releaseStrategy，但我只能在其中定义最大大小，然后剩下的消息(在我的例子中是4条消息)正在聚合器中等待更多的消息(因此满足最大大小条件)。我不想等待聚合器超时，因为我知道我的列表的大
浏览 1提问于2015-06-26得票数 2
回答已采纳
我正在监听来自activeMq embedded broker队列的消息(比如原始消息)。此消息首先移动到通道，然后传递到路由器，并根据传递到aggregator.Aggregator的条件等待另一条消息，然后将部分或聚合消息传递给服务激活器类。如果没有聚合器，如果达到最大重试次数，消息将被正确地重新传递并移动到DLQ，但如果聚合器出现，消息将不会被重新传递。我不确定，但我认为聚合消息</e
浏览 16提问于2016-08-25得票数 2
您好，我的输入文件如下所示AAA,2BBB,1CCC,2DDD,5EEE,1AAA,3CCC,1CCC,2DDD,5EEE,1
CCC，% 2应写入消息%1或CCC，%1应写入消息%2。对于上面的示例，其工作原理类似于“如果有更多以CCC开头的记录，则在消息中聚合5条记录，也将它们放到<
浏览 19提问于2016-08-17得票数 1
回答已采纳
我们有一个拆分器进程，它将消息推送到不同的队列。还有另一个收集和聚合这些消息以供进一步处理的过程。解决这个问题的最佳解决方案是什么？
浏览 1提问于2016-10-05得票数 1
所有spring项目都有广泛且非常有用的文档，spring集成项目的情况也是如此，但我想要收集的一个主题是消息组收割者。基本上，它似乎是一种机制，可以在外部影响聚合器发布一些消息。它实际上是从聚合器释放消息，然后由流中的后续组件处理，还是只清空聚合器，就像丢弃聚合消息一样。第二，是否控制哪些消息被发布，从而释放属于特定组的消息，而不是其他消息。
浏览 4提问于2014-05-06得票数 3
回答已采纳
我正在从rabbit上拉取消息并聚合它们。我注意到，即使使用autoAck=false，消息一旦聚合就会被确认。这意味着如果我的进程崩溃，消息将不会重新排队等待rety。我插入了leveldb java db作为聚合repo，它解决了这个问题，因为我假设它只有在聚合并存储在repo中时才会确认。问题是，有没有什么我可以做的，这样Camel只会在聚合消息完成其旅程后才接受交换的消息？聚合之后，我的下一
浏览 13提问于2017-07-07得票数 1
回答已采纳
我们有一个包含2个聚合器、一些转换器、适配器等的Spring Integration上下文……此上下文使用来自ActiveMQ队列的消息，以及2个them服务，并将它们放入聚合器中。我们想要实现的是，每当我们在一个具体的队列中接收到一条消息时，我们将重置聚合器和每个statefull组件中的所有消息，以启动每个批处理过程(由队列中的start消息触发)完全空白和干净。那么，如何根据队列中收到的消息重置聚合器组件呢？
浏览 6提问于2017-02-21得票数 1
回答已采纳
我使用的是spring集成，我使用的是默认的关联策略，也就是说，我没有显式地为关联策略编写代码，在拆分器之前，一切都运行得很好，在拆分器之后，有一个服务激活器，它进行一些处理，然后将消息放入聚合器必须从中挑选消息的通道中，但聚合器不会从中挑选消息，所以我放置了一个拦截器来找出发生了什么，并发现在将消息放入聚合器通道之前，存在与聚合相关的头部，比如关联id等。但是一旦它被放到通道中，报头是lost.Now的，我不确定为什么聚合器或之前的
浏览 15提问于2017-07-17得票数 0
我有分组获取到系统的消息(比如50条消息)，需要通过AGGREGATION_ID将其分组到消息列表中，然后再发送到流中。我可以使用correlationStrategy来使用该id进行聚合，但我需要知道何时发布聚合消息。在ReleaseStrategy中，我只能查看已经添加到聚合中的消息，但我需要知道在具有相同AGGREGATION_ID的获取组中何时不再有消息，以知道何时发送该组。我怎么能这么做？
浏览 1提问于2020-04-06得票数 0
回答已采纳
要求是，我必须使用拆分器拆分消息，并在某些转换过程中向拆分后的消息添加一个标头值，并在稍后进行聚合。但是聚合后，我添加的邮件拆分器的标头值丢失了。这是由于聚合策略造成的吗？我使用的是默认策略。请建议如何持久化标题并在聚合后使用它的方法。这样我就可以做一些自定义转换了。
浏览 1提问于2017-09-07得票数 1
我想在我的链中放置一个aggregator，它聚合所有传入消息(字符串)，并在特定时刻释放聚合消息(String)，我希望使用"cron表达式“(类似于在计票器中使用的表达式)来定义聚合消息(String
浏览 3提问于2015-07-15得票数 3
回答已采纳
1回答
看一看AbstractCorrelatingMessageHandler的代码，似乎聚合器根据关联id获得了一个锁，以强制单个线程处理属于同一关联id的消息组。这是有意义的，事实上，我希望确保消息一旦从聚合器释放出来，只要消息是由同一线程中的任何下游组件处理的，聚合器就不应该释放属于相同关联id的任何消息(如果它们进来的话)。例如，如果我以关联id作为"1“发送消息"A”，并立即发送属于同一关联id的消息"
浏览 0提问于2014-06-09得票数 1
回答已采纳
我正在开发一个基于java (+netty)的系统，它接收来自客户端的不同类型的消息，聚合它们并将聚合结果推送到存储中。
I需要在聚合之前预先积累消息，直到满足两种条件之一--超过超时或超过数量。之后，我聚合/减少相同类型和发送方的消息，并将结果推送到存储中。聚合可能类似于计算消息之间的平均值。或者可能要复杂得多。在我的情况下，存储中的后聚合是不可接受的。显然，我需要收集某些数据结构中的消息</em
浏览 1提问于2014-04-05得票数 1
回答已采纳
在Apache Camel中，有没有办法在时间范围内聚合消息。我想通过推送一条消息并从另一端消费来计算我的系统的即时TPS。在消费者端，我想做一个聚合器，它聚合在一定时间范围内(比方说1秒)传递的消息，并提供一些计算。谢谢。
浏览 1提问于2014-12-22得票数 0
每个消息(报头(1)、数据(n)、结束(1))应该接收响应，但是对“结束”消息的响应应该基于“报头”，以及接收到的任何“数据”消息以及“结束”消息。目前，我正在将消息路由到聚合器，当它找到特定相关id的“头”和“结束”消息时，聚合器就会完成。不幸的是，在此之前(或同时？)消息被发送到聚合器，因此在构建响应时，我无法访问聚合消息(它包含构建正确响应所需的所有数据)。
有没有一种不需要
浏览 0提问于2012-08-06得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
