我需要实现一个spring集成流程,在该流程中,只有在满足特定条件时才可以处理某些消息,即这些消息需要等待。但是,我不想阻止流程。是否有执行此操作的组件?
如果实例关闭,数据丢失也没有风险,因为数据将保留在内存中(您可以尝试将其临时存储并在VM崩溃的情况下重新注入)。
spring实现了一个集成模式,称为Aggregator,可以用于此目的(链接到pattern和spring docs)
您将需要实现一个CorrelationStrategy
,该功能可以告诉spring不同消息之间的关联方式,并且ReleaseStrategy
可以通知spring所需的所有项目何时到达,因此它们可以继续进行。
我将再次重复这一过程,所有运行中的数据都保存在内存中,因此您必须弄清楚关机/崩溃后如何存储和重新注入数据。
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句