Criteria-based message publication control and feedback in a publish/subscribe messaging environment
First Claim
1. A computer-implemented method of criteria-based message publication control and feedback in a publish/subscribe messaging environment, comprising:
- receiving, at a message broker, a message published by a message publisher, the message having associated therewith a topic and classification criteria, the classification criteria specifying requirements for determining whether publication of the message is successful;
consulting, by the message broker, a subscription registry to locate registered subscriptions of a plurality of message subscribers that have registered with the message broker to receive published messages having the topic, each of the registered subscriptions further specifying subscriber classification information pertaining to the topic;
selecting, by the message broker from the located subscriptions, each of at least one of the located subscriptions for which the registered subscriber classification information matches the classification criteria associated with the message, wherein the registered subscriber classification information for at least one of the located subscriptions does not match the classification criteria associated with the message;
identifying, for each of the at least one selected subscription, the subscriber that registered the selected subscription;
sending the message, by the message broker, to the each identified subscriber;
comparing, by the message broker, the subscriber classification information in the at least one selected subscription to the classification criteria associated with the message to determine whether the requirements specified in the classification criteria are met by the at least one selected subscription; and
responsive to determining, by the comparing, that the requirements are not met, performing controlled failure handling, the controlled failure handling comprising;
responsive to determining that a mode of failure handling applicable for the message indicates a warning mode, sending the message, by the message broker, to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting and warning the message publisher that publication of the message was not successful; and
responsive to determining that the mode of failure handling indicates a failure mode, notifying the message publisher that publication of the message failed while omitting the sending of the message to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting.
1 Assignment
0 Petitions
Accused Products
Abstract
Control and/or feedback are provided for message publication in a publish/subscribe messaging environment. A number of different aspects are disclosed, and an embodiment may include one or more of these aspects. In each aspect, each subscribing application has an associated importance level for a subscription, and this importance level may vary among subscriptions for different message topics. Each published message has an associated topic. In some aspects, each published message also has associated criteria, where the criteria are specified with regard to message classification. In preferred embodiments, the message classification comprises importance criteria specifying requirements for importance level of subscribers registered for the topic of that message. Feedback can be provided regarding whether a message publication meets the importance criteria. Control over message publication can be based on whether a message publication meets the importance criteria.
-
Citations
16 Claims
-
1. A computer-implemented method of criteria-based message publication control and feedback in a publish/subscribe messaging environment, comprising:
-
receiving, at a message broker, a message published by a message publisher, the message having associated therewith a topic and classification criteria, the classification criteria specifying requirements for determining whether publication of the message is successful; consulting, by the message broker, a subscription registry to locate registered subscriptions of a plurality of message subscribers that have registered with the message broker to receive published messages having the topic, each of the registered subscriptions further specifying subscriber classification information pertaining to the topic; selecting, by the message broker from the located subscriptions, each of at least one of the located subscriptions for which the registered subscriber classification information matches the classification criteria associated with the message, wherein the registered subscriber classification information for at least one of the located subscriptions does not match the classification criteria associated with the message; identifying, for each of the at least one selected subscription, the subscriber that registered the selected subscription; sending the message, by the message broker, to the each identified subscriber; comparing, by the message broker, the subscriber classification information in the at least one selected subscription to the classification criteria associated with the message to determine whether the requirements specified in the classification criteria are met by the at least one selected subscription; and responsive to determining, by the comparing, that the requirements are not met, performing controlled failure handling, the controlled failure handling comprising; responsive to determining that a mode of failure handling applicable for the message indicates a warning mode, sending the message, by the message broker, to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting and warning the message publisher that publication of the message was not successful; and responsive to determining that the mode of failure handling indicates a failure mode, notifying the message publisher that publication of the message failed while omitting the sending of the message to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14)
-
-
15. A system for criteria-based message publication control and feedback in a publish/subscribe messaging environment, comprising:
-
a computer comprising a processor; and instructions which are executable, using the processor, to implement functions comprising; receiving, at a message broker, a message published by a message publisher, the message having associated therewith a topic and classification criteria, the classification criteria specifying requirements for determining whether publication of the message is successful; consulting, by the message broker, a subscription registry to locate registered subscriptions of a plurality of message subscribers that have registered with the message broker to receive published messages having the topic, each of the registered subscriptions further specifying subscriber classification information pertaining to the topic; selecting, by the message broker from the located subscriptions, each of at least one of the located subscriptions for which the registered subscriber classification information matches the classification criteria associated with the message, wherein the registered subscriber classification information for at least one of the located subscriptions does not match the classification criteria associated with the message; identifying, for each of the at least one selected subscription, the subscriber that registered the selected subscription; sending the message, by the message broker, to the each identified subscriber; comparing, by the message broker, the subscriber classification information in the at least one selected subscription to the classification criteria associated with the message to determine whether the requirements specified in the classification criteria are met by the at least one selected subscription; and responsive to determining, by the comparing, that the requirements are not met, performing controlled failure handling, the controlled failure handling comprising; responsive to determining that a mode of failure handling applicable for the message indicates a warning mode, sending the message, by the message broker, to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting and warning the message publisher that publication of the message was not successful; and responsive to determining that the mode of failure handling indicates a failure mode, notifying the message publisher that publication of the message failed while omitting the sending of the message to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting.
-
-
16. A computer program product for criteria-based message publication control and feedback in a publish/subscribe messaging environment, the computer program product comprising:
a non-transitory computer readable storage medium having computer readable program code embodied therein, the computer readable program code configured for; receiving, at a message broker, a message published by a message publisher, the message having associated therewith a topic and classification criteria, the classification criteria specifying requirements for determining whether publication of the message is successful; consulting, by the message broker, a subscription registry to locate registered subscriptions of a plurality of message subscribers that have registered with the message broker to receive published messages having the topic, each of the registered subscriptions further specifying subscriber classification information pertaining to the topic; selecting, by the message broker from the located subscriptions, each of at least one of the located subscriptions for which the registered subscriber classification information matches the classification criteria associated with the message, wherein the registered subscriber classification information for at least one of the located subscriptions does not match the classification criteria associated with the message; identifying, for each of the at least one selected subscription, the subscriber that registered the selected subscription; sending the message, by the message broker, to the each identified subscriber; comparing, by the message broker, the subscriber classification information in the at least one selected subscription to the classification criteria associated with the message to determine whether the requirements specified in the classification criteria are met by the at least one selected subscription; and responsive to determining, by the comparing, that the requirements are not met, performing controlled failure handling, the controlled failure handling comprising; responsive to determining that a mode of failure handling applicable for the message indicates a warning mode, sending the message, by the message broker, to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting and warning the message publisher that publication of the message was not successful; and responsive to determining that the mode of failure handling indicates a failure mode, notifying the message publisher that publication of the message failed while omitting the sending of the message to each of the message subscribers that registered one of the located subscriptions which was not selected by the selecting.
Specification