Controlling message delivery in publish/subscribe messaging

摘要

In response to publication of a topic message on a topic to a messaging system by a publisher application, a determination is made as to whether any subscriber applications are registered for the topic. In response to determining that at least one subscriber application is registered for the topic, the published topic message is delivered to each registered subscriber application. In response to determining that no subscriber applications are registered for the topic, the published topic message is stored and in response to receipt of a first subsequent subscription request from a new subscriber application for the topic, the stored published topic message is delivered to the new subscriber application.

主权项

1. A method, comprising:
determining, in response to publication of a topic message on a topic to a messaging system by a publisher application, whether any subscriber applications are registered for the topic; delivering, in response to determining that at least one subscriber application is registered for the topic, the published topic message to each registered subscriber application; and in response to determining that no subscriber applications are registered for the topic:
storing the published topic message;delivering, in response to receipt of a first subsequent subscription request from a new subscriber application for the topic, the stored published topic message to the new subscriber application;delivering the stored published topic message to any other new subscriber applications that register for the topic within a first predetermined time of the first subsequent subscription request prior to discarding the stored published topic message, where the first predetermined time is configurable to zero to allow configuration of stored message delivery only to subscriber applications that register for the topic simultaneously with the new subscriber application; anddiscarding the stored published topic message if no subscriber application registers for the topic within a second predetermined time of publication of the topic message on the topic.