我需要创建一个供 Mule ESB 应用程序使用的“累加器”服务。
此服务将保留入站消息,直到收到一定数量的消息,然后将这些消息打包成单个出站消息。
这是我第一次需要编写一个 ESB 应用程序,该应用程序需要跨入站消息维护状态(先前接收到的消息的集合),我不太确定如何开始。
我认为我需要一个地方来挂起对包含入站消息列表的数据结构的引用,但我不确定。
管理“应用程序级”(即跨消息)状态数据的最佳(最高效、最符合 ESB 最佳实践)机制是什么?
谢谢。
我需要创建一个供 Mule ESB 应用程序使用的“累加器”服务。
此服务将保留入站消息,直到收到一定数量的消息,然后将这些消息打包成单个出站消息。
这是我第一次需要编写一个 ESB 应用程序,该应用程序需要跨入站消息维护状态(先前接收到的消息的集合),我不太确定如何开始。
我认为我需要一个地方来挂起对包含入站消息列表的数据结构的引用,但我不确定。
管理“应用程序级”(即跨消息)状态数据的最佳(最高效、最符合 ESB 最佳实践)机制是什么?
谢谢。
对于这种情况,您需要使用聚合器模式。请点击以下链接。 http://www.mulesoft.org/documentation-3.2/display/32X/Message+Splitting+and+Aggregation