我们正在使用Spring Integration 4.2.3聚合器组件和定义的group-timeout，并期望组在给定的超时值内超时，同时向组添加消息&不符合发布大小标准。但我们看到了不同的结果，当我们向服务输入重载时，聚合器将等待所有消息被添加到组中，而不是在超时到达时使组过期。
当组超时时，有没有办法覆盖聚
浏览 11提问于2018-01-13得票数 3
我使用SI的聚合器模式来保存事件，等待完成事件，并将其存储在JdbcMessage存储中。我已经在管道中指定了以下配置 .expireGroupsUponTimeoutgroupTimeout(groupMessageTimeOut)
.sendPartialResultOnExpiry(fals
浏览 19提问于2020-02-06得票数 0
这是Spring Integration AWS RabbitMQ Kinesis的后续问题 我有以下配置。我注意到，当我第一次向名为kinesisSendChannel的输入通道发送消息时，将调用聚合器和发布策略，并将消息发送到Kinesis Streams。我将调试断点放在不同的位置，并且可以验证此行为。但是，当我再次将消息发布到相同的输入通道时，不会调用发布策略和出站处理器，
浏览 28提问于2021-10-12得票数 0
回答已采纳
1回答
我正在使用SpringXD1.3.0发行版来处理元组消息。因此，我粗略地复制了原始spring聚合器的原始。=${spring.datasource.url} --initializeData
浏览 4提问于2016-01-14得票数 1
回答已采纳
我在Spring Integration流程中通过Java DSL配置了一个聚合器，我想抛出一个异常，当发生组超时时，该异常会转到全局错误通道。丢弃通道对我没有好处，因为丢弃消息是在组成员级别，而不是整个组。我尝试使用应用程序事件发布器，如下所示，但publisher对象似乎没有被调用：
.aggregate(new Consumer<AggregatorSpec>() {e.printStackT
浏览 6提问于2016-08-11得票数 2
回答已采纳
AFAIK是一个基于Spring Integration的Spring Cloud Stream项目。因此，我想知道是否有一种很好的方法来在StreamListener处理程序被触发之前重新排序入站消息的子集？或者，我是否需要使用XML或Spring Integration中的Java DSL config从头组装整个IntegrationFlow？
我的用例如下。大多数时候，我处
浏览 4提问于2018-11-22得票数 1
我们有一个包含2个聚合器、一些转换器、适配器等的Spring Integration上下文……此上下文使用来自ActiveMQ队列的消息，以及2个them服务，并将它们放入聚合器中。我们想要实现的是，每当我们在一个具体的队列中接收到一条消息时，我们将重置聚合器和每个statefull组件中的所
浏览 6提问于2017-02-21得票数 1
回答已采纳
我是Spring Integration的新手，我想知道Spring Integration中是否存在一个组件，它可以帮助我将2个渠道的结果结合起来。我知道答案是聚合器，但是我不希望消息合并到一个消息中，但当来自两个通道的消息到达时，它们应该流向下游组件。这是一种循环屏障的情况。
谢谢你，阿迪
浏览 2提问于2014-12-17得票数 0
我有spring集成流，每天触发一次，从数据库中拉出所有各方，并将每一方发送到executorChannel。下一个流将拉取每一方的数据，然后通过发送到不同的executor通道来并行处理它们。我面临的挑战是如何知道整个过程何时结束。任何关于如何达到这一点的想法。下面是我的executor通道和集成流的伪代码。
浏览 53提问于2021-10-25得票数 1
我们正在实现Spring Integration聚合器并使用JDBC消息数据存储。在我们的环境中，我们有Couchbase和Oracle DB。我不想使用Oracle DB，我们可以使用couchbase作为消息库吗？如果是，你能建议一下方法吗？
浏览 9提问于2019-12-18得票数 1
1回答
在Spring集成中，我使用了拆分器和聚合器两种不同的结构， 当我在系统上执行负载测试时，实现聚合器的服务使用的内存(堆)以与我提供的数据相同的速度增加，并且保持不变。有什么地方我用错了吗？我在消息组完成时删除它们，并且当我检查计数时，消息组存储返回0。SimpleSequenceSizeReleaseStra
浏览 45提问于2021-10-01得票数 0
回答已采纳
我有一个简单的SpringIntegration2.0.1聚合器设置，它使用了一个SimpleMessageStore和定义的一个普通的Spring MessageGroupStoreReaper，以便能够实现分组超时机制(在SpringIntegration1.0.4中它只是作为聚合器‘超时值’的一个参数工作)。我已经调试并验证了基于SimpleMessageStore的groupId正确地<em
浏览 2提问于2013-11-06得票数 0
回答已采纳
我使用的是Spring boot 2.0.x和Spring integration 5.0.x。我可以使用correlationStrategy和releaseStrategy的自定义逻辑成功地实现事件的聚合，我不需要使用拆分器。如果我更改correlationStrategy /release策略逻辑并重新部署应用程序，消息存储中以前的消息会卡住，即使在超时后也不会释放
浏览 1提问于2020-07-06得票数 1
我们让Spring Integration聚合器组件在多个实例中运行，但都指向相同的JDBCMessageStore (oracle)。我知道我们可以根据主机名设置区域，以便聚合器聚合与特定主机相关的消息。
但是，有没有什么方法可以跨所有实例使用默认区域，而仍然只有一个实例聚合消息存储库中的所有消息？
浏览 0提问于2018-01-25得票数 1
2回答
我正在尝试理解在RabbitMQ中合并或分块传入消息的最佳方法(直接使用Spring AMQP或Java client )。换句话说，我想接受100条传入消息，并将它们组合为1，然后以可靠(正确地ACKed )的方式将其重新发送到另一个队列。我相信这在企业信息门户中被称为模式。我知道Spring Integration ，但它的实现看起来并不安全(这就是说，它看起来必须确认并使用消息来构建合并的<e
浏览 4提问于2013-02-25得票数 2
回答已采纳
我将消息发送到聚合器的输入通道，然后聚合器将聚合消息释放到输出通道。聚合器期望至少有2条消息(用于聚合)，否则等待10秒超时。我还使用jdbc消息存储。场景1运行良好。发送消息1和2 ->输入通道(input1) ->聚合器1 ->输出通道(outp
浏览 2提问于2015-10-30得票数 1
回答已采纳
我们的应用程序中存在以下问题。消息通过入站通道适配器传入，并使用持久消息存储在聚合器中累积。一旦发布策略中定义的条件返回true，消息就被发送到处理的下一个阶段。如果在处理下一阶段抛出异常，则将回滚事务，并将消息再次放入持久消息存储中。但是，事务不会将消息放回原始队列中，因为消息一旦放入聚合器中就会被确认。这不是我们想要
浏览 2提问于2014-01-26得票数 0
我正在使用Spring Integration构建一个工作应用程序，并且我对该框架完全陌生。我看到的问题是，当消息在处理程序中失败时，它似乎以某种方式重新排队。我在日志中看到
浏览 1提问于2018-03-16得票数 2
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
