具有可配置保证的分布式消息收发系统

摘要

本发明涉及用于在分布式消息收发系统内配置保证的方法、系统和计算机程序产品。一组定义的消息日志和游标组件可通过配置来激活和停用以在分布式消息收发系统内组成各种不同的捕捉保证、传输保证、以及送达保证。捕捉保证、传输保证、以及送达保证的合成可为消息收发系统提供端对端保证。端对端保证可包括最大努力、至多一次、至少一次、以及正好一次中的一个，并可包括以下之一：耐久或非耐久。使用一组定义的可激活和可停用消息日志和游标组件便于更高效地在所需保证之间进行转换。在一些实施例中，捕捉保证、传输保证、以及送达保证的合成提供耐久的正好一次消息传递。

主权项

一种具有可配置保证的组件化消息收发系统(100)，包括：被配置成存储消息的消息日志(102)，所述消息日志包括一个或多个处理器、系统存储器、以及用于组成一组可扩展捕捉协议中的任一种以捕捉来自消息生产者(105)的消息(164)的消息日志组件(152)，所述一组可扩展捕捉协议被配置成提供来自一组消息捕捉保证(201)内的各种不同的消息捕捉保证中的任一种，所述一组消息捕捉保证在耐久存储(122)的使用中变化并在事务的使用中变化；被配置成跟踪消费者(107)在所述消息日志(102)中的消息中的进展的游标(103)，所述游标(103)包括一个或多个处理器、系统存储器、以及用于组成一组可扩展送达协议中的任一种以将消息(164)送达消息消费者(107)的游标组件(153)，所述一组可扩展送达协议被配置成提供来自一组消息送达保证(203)内的各种不同的消息送达保证中的任一种，所述一组消息送达保证在耐久存储(122)的使用中变化并在事务的使用中变化；以及其中所述消息日志(102)和所述游标(103)各自还包括用于彼此互操作以组成一组可扩展传输协议中的任一种以将消息从所述消息日志(102)传输到分开的游标(103)的其他组件，所述一组可扩展传输协议被配置成提供来自一组消息传输保证(202)内的各种不同的消息传输保证中的任一种，所述一组消息传输保证在时间窗的使用中变化并在已确认送达的使用中变化。