0

我对消息存储中的消息处理有一个奇怪的行为。

我有一个将消息放入消息存储的代理服务和一个从消息存储获取消息并调用端点的消息处理器。

如果消息被正确处理，则调用一个序列；在这个序列中，我对表启动更新查询。

好吧，没有任何延迟地向消息存储发送 500/1000，我注意到带有查询的序列并不总是被调用，并且日志中没有写入任何错误。

如果我停用消息处理器并让该消息存储由 500/1000 条消息填充，则重新激活消息处理器总是正确调用序列。

您是否知道 Message-Processor （我的 Message-Processor 是 Scheduled 类型）必须同时处理大量消息时是否存在一些问题？

此外，Wso2Esb 使用多少个 Message-Processor 实例来处理 Message-Store 中包含的消息？（ 一个或多个 ？ ）。

如果消息处理器的不同实例可能存在线程并发问题。

干杯。

            warxsg
4

1 回答 1

0

您使用的 ESB 版本是什么。你能告诉我你使用的消息处理器是什么吗？例如：MessageForwading 处理器？采样处理器？

http://wso2.org/library/articles/2011/10/implementing-store-forward-messaging-patterns-wso2esb-part-1和 http://wso2.org/library/articles/2011/12/implementing-存储转发消息模式-wso2esb-part-2

可能会有所帮助。

干杯，

于 2013-03-15T06:45:11.517 回答