Identifying subscriber data while processing publisher event in transaction

摘要

A solution for managing messaging is provided in which an event related to a publisher is identified. In response to the event, a transaction is initiated for processing the event, the event is processed within the transaction, and the transaction is committed after the event is processed. During processing, data corresponding to the event is provided for use by a set of subscribers to the event, and data related to the set of subscribers is identified. In an embodiment, a message broker in a publication and subscribe messaging environment implements the solution in order to be capable of providing the data related to the set of subscribers to the publisher. Use of the transaction ensures that the data related to the set of subscribers accurately represents the set of subscribers at the time that the data corresponding to the event was provided.

主权项

1. A computer-implemented method of managing messaging, the method comprising:
identifying a topic for a periodic publication related to a publisher using a message broker; initiating a transaction on the message broker for processing the periodic publication in response to the identifying; processing the periodic publication within the transaction using the message broker, the processing including:
identifying a set of subscribers to the periodic publication using the topic;providing data corresponding to the periodic publication for use by the set of subscribers to the periodic publication;locking an item of the data that the message broker is excluded from reading or modifying during the processing, wherein the locking prevents another process from modifying the item of the data;receiving subscriber metadata for the set of subscribers corresponding to a set of fields included with the topic, wherein the set of fields includes at least one field indicating that the subscriber metadata is requested by the publisher, wherein the subscriber metadata includes data related to the set of subscribers to the periodic publication representing the set of subscribers at the time that the data corresponding to the periodic publication was provided; andproviding a response for use by the publisher, wherein the response includes the subscriber metadata for the set of subscribers corresponding to the set of fields included with the topic; and committing the transaction after the processing.