System, method, and computer program for an exactly once messaging protocol in a publish-subscribe messaging system
AssigneeAmdocs Development Limited
InventorsTehila Atar, Nir Makmal
Life of this patent
Estimating the term…
Abstract
As described herein, a system, method, and computer program are provided for an exactly once messaging protocol in a publish-subscribe messaging system. A consumer (i.e. subscriber) of a publish-subscribe messaging system is identified. For each required consumer, and for each subscribed topic of the consumer, a new dedicated consumer is created for the topic in the publish-subscribe messaging system. The new dedicated consumer is used to ensure that messages published to the topic are delivered exactly once to each associated consumer.
Claims19
A non-transitory computer-readable media storing computer instructions which when executed by one or more processors of a device cause the device to:
- identify a consumer and its subscribed topics in a publish-subscribe messaging system;
- for each required consumer, and for each subscribed topic of the consumer:
- determine that an idempotency flag is enabled for the topic of the publish-subscribe messaging system, and
- create a new dedicated consumer for the topic in the publish-subscribe messaging system when the idempotency flag is enabled on an associated consumer configuration for the topic of the publish-subscribe messaging system;
- use the new dedicated consumer to ensure that messages published to the topic are delivered exactly once to each associated consumer.
A method, comprising:
- at a computer system:
- identifying a consumer and its subscribed topics in a publish-subscribe messaging system;
- for each required consumer, and for each subscribed topic of the consumer, creating a new dedicated consumer for the topic in the publish-subscribe messaging system;
- using the new dedicated consumer to ensure that messages published to the topic are delivered exactly once to each associated consumer
- wherein a maximum position of each message published to the topic that reaches a point of no return on a consuming flow of an associated consumer is stored in the new dedicated consumer.
A system, comprising:
- a non-transitory memory storing instructions;
- and
- one or more processors in communication with the non-transitory memory that execute the instructions to:
- identify a consumer and its subscribed topics in a publish-subscribe messaging system;
- for each required consumer, and for each subscribed topic of the consumer, create a new dedicated consumer for the topic in the publish-subscribe messaging system;
- use the new dedicated consumer to ensure that messages published to the topic are delivered exactly once to each associated consumer;
- wherein the new dedicated consumer is used to indicate a lowest offset of a message that has not yet reached a point of no return.
Dependencies are inferred from the claim text.