Message processing control in a publish/subscribe system
First Claim
1. For use in a publish/subscriber system in which a published message originating with a publisher is identified by an associated topic string and originally includes a PubLevel value assigned by the publisher, a broker apparatus comprising:
- a receiver component for receiving the published message;
a subscriber selection component for selecting a subscriber from a set of one or more subscriber candidates that have registered a subscription with the broker to receive published messages identified by the associated topic string, each of said subscriber candidates having an associated SubLevel value;
a publication control component for changing the PubLevel value associated with the published message as a function of the SubLevel value associated with the subscriber selected by the subscriber selection component; and
a transmit component for forwarding the published message to the subscriber selected by the subscriber selection component.
2 Assignments
0 Petitions
Accused Products
Abstract
Messages in a publish/subscribe system can be processed after they leave the original publisher and before they are delivered to an ultimate subscriber. Each published message has an associated topic string and a PubLevel value initially assigned by the original publisher. Subscribers are assigned different SubLevel values. These subscribers register their subscriptions with a broker. When a published message having the appropriate topic string is received, the broker performs a subscriber selection process using the message topic string, the current message PubLevel value and the assigned SubLevel values of subscribers registered for the topic string. When a subscriber is selected, the broker changes the message PubLevel value and transmits the message only to the selected subscriber. The subscriber may be an intercepting subscriber that processes the published message and then re-publishes it back to the broker. The broker may repeat the subscriber selection process multiple times with the published message being sent to multiple intercepting systems, each of which processes and republishes the message before the processed message is finally sent by the broker to an ultimate subscriber.
15 Citations
12 Claims
-
1. For use in a publish/subscriber system in which a published message originating with a publisher is identified by an associated topic string and originally includes a PubLevel value assigned by the publisher, a broker apparatus comprising:
-
a receiver component for receiving the published message; a subscriber selection component for selecting a subscriber from a set of one or more subscriber candidates that have registered a subscription with the broker to receive published messages identified by the associated topic string, each of said subscriber candidates having an associated SubLevel value; a publication control component for changing the PubLevel value associated with the published message as a function of the SubLevel value associated with the subscriber selected by the subscriber selection component; and a transmit component for forwarding the published message to the subscriber selected by the subscriber selection component. - View Dependent Claims (2, 3, 4)
-
-
5. For performance in a broker apparatus in a publish/subscribe system in which a published message originating with a publisher is identified by an associated topic string and originally includes an associated PubLevel value assigned by the publisher, a method of processing a published message comprising:
-
receiving the published message; identifying both a topic string associated with the published message and the value of the PubLevel value currently assigned to the published message; selecting a subscriber to receive the published message from a set of one or more subscriber candidates that have registered subscriptions with the broker apparatus to receive published messages identified by the topic string associated with the published message, each of said subscriber candidates having an associated SubLevel value; changing the PubLevel value assigned to the published message as a function of the SubLevel value associated with the subscriber selected to receive the published message; and sending the published message to the subscriber selected to receive the published message. - View Dependent Claims (6, 7, 8)
-
-
9. A computer program product for controlling the processing of messages at a broker apparatus in a publish/subscribe system in which a published message originating with a publisher is identified by an associated topic string and originally includes an PubLevel value originally assigned by the publisher, said computer program product comprising a non-transitory computer usable medium having computer usable program code embodied therein, said computer usable program code comprising:
-
computer usable program code configured to receive the published message; computer usable program code configured to identify both a topic string associated with the published message and the value of the PubLevel value currently assigned to the published message; computer usable program code configured to select a subscriber to receive the published message from a set of one or more subscriber candidates that have registered subscriptions with the broker apparatus to receive published messages identified by the topic string associated with the published message, each of said subscriber candidates having an associated SubLevel value; computer usable program code configured to change the PubLevel value assigned to the published message as a function of the SubLevel value associated with the subscriber selected to receive the published message; and computer usable program code configured to send the published message to the subscriber selected to receive the published message. - View Dependent Claims (10, 11, 12)
-
Specification