US Patent 11063780 Eventually consistent data replication in queue-based messaging systems

Techniques are disclosed herein for ensuring convergence of states for reliable message delivery in geographically distributed message queuing systems. The techniques include receiving a message at a local system, in which the message is associated with a new message topic. Further, at least one commutative replicated data type (CRDT) object associated with the message is created, wherein the at least one CRDT object corresponds to a unique message identifier (ID). A new message state corresponding to the message ID and the message topic is entered in a message state table, wherein the message state entry indicates a message state corresponding to the message. At least one CRDT object is recorded in a message queue. Thereafter, a list of subscribers including individual subscribers mapped to the new message topic is resolved from a message destinations object. The message is then delivered to at least one of the individual subscribers.