CPC H04L 51/226 (2022.05) [H04L 51/216 (2022.05)] | 19 Claims |
18. 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.
|