Apparatus for controlling subscriptions
First Claim
Patent Images
1. An apparatus for controlling subscriptions, the apparatus comprising:
- a processor;
a non-transitory computer-readable storage having stored thereon a computer program configured for controlling the processor to perform the steps of;
assigning one of a PASSTHROUGH value and a BLOCK value to a first attribute of each topic node of a topic tree based on at least one assignment rule;
responsive to a wildcard topic string, determining a highest level topic node of the topic tree matching the wildcard topic string to define a root node;
traversing each topic node of the topic tree starting the root node, the traversing comprising;
analyzing the first attribute of the topic node to determine whether the first attribute specifies the PASSTHROUGH value or the BLOCK value,if the first attribute specifies the PASSTHROUGH value, determining a subscriber associated with the subscription should receive a message associated with the topic string of the topic node, andif the first attribute specifies the BLOCK value, determining that the subscriber should not receive a message associated with the topic string of the topic node or a message associated with other topic strings more specific than the topic string of the topic node when the wildcard topic string is less specific than the topic string of the topic node;
detecting a generation of a new topic node; and
performing the traversing for the new topic node.
1 Assignment
0 Petitions
Accused Products
Abstract
An apparatus for controlling subscriptions comprising: a detector operable to detect to a subscription associated with a wildcard topic string; and an analyzer, responsive to the detection of the subscription associated with a wildcard topic string and a topic string of a topic node matching the wildcard topic string, for analyzing a first attribute of the topic node; and means for determining whether a subscriber associated with the subscription should receive a message associated with the topic string of the topic node.
-
Citations
7 Claims
-
1. An apparatus for controlling subscriptions, the apparatus comprising:
-
a processor; a non-transitory computer-readable storage having stored thereon a computer program configured for controlling the processor to perform the steps of; assigning one of a PASSTHROUGH value and a BLOCK value to a first attribute of each topic node of a topic tree based on at least one assignment rule; responsive to a wildcard topic string, determining a highest level topic node of the topic tree matching the wildcard topic string to define a root node; traversing each topic node of the topic tree starting the root node, the traversing comprising; analyzing the first attribute of the topic node to determine whether the first attribute specifies the PASSTHROUGH value or the BLOCK value, if the first attribute specifies the PASSTHROUGH value, determining a subscriber associated with the subscription should receive a message associated with the topic string of the topic node, and if the first attribute specifies the BLOCK value, determining that the subscriber should not receive a message associated with the topic string of the topic node or a message associated with other topic strings more specific than the topic string of the topic node when the wildcard topic string is less specific than the topic string of the topic node; detecting a generation of a new topic node; and performing the traversing for the new topic node. - View Dependent Claims (2, 3)
-
-
4. A method for controlling subscriptions, the method comprising:
-
assigning one of a PASSTHROUGH value and a BLOCK value to a first attribute of each topic node of a topic tree based on at least one assignment rule; responsive to a wildcard topic string, determining a highest level topic node of the topic tree matching the wildcard topic string to define a root node; traversing, via a processor, each topic node of the topic tree starting the root node, the traversing comprising; analyzing the first attribute of the topic node to determine whether the first attribute specifies the PASSTHROUGH value or the BLOCK value, if the first attribute specifies the PASSTHROUGH value, determining a subscriber associated with the subscription should receive a message associated with the topic string of the topic node, and if the first attribute specifies the BLOCK value, determining that the subscriber should not receive a message associated with the topic string of the topic node and topic strings more specific than the topic string of the topic node when the wildcard topic string is less specific than the topic string of the topic node; detecting a generation of a new topic node; and performing the traversing for the new topic node. - View Dependent Claims (5, 6)
-
-
7. A non-transitory computer-readable storage-medium containing a computer program comprising program code, which, when loaded in and executed by a computer causes the computer to perform the steps of:
-
assigning one of a PASSTHROUGH value and a BLOCK value to a first attribute of each topic node of a topic tree based on at least one assignment rule; responsive to a wildcard topic string, determining a highest level topic node of the topic tree matching the wildcard topic string to define a root node; and traversing, via a processor, each topic node of the topic tree starting the root node, the traversing comprising; analyzing the first attribute of the topic node to determine whether the first attribute specifies the PASSTHROUGH value or the BLOCK value, if the first attribute specifies the PASSTHROUGH value, determining a subscriber associated with the subscription should receive a message associated with the topic string of the topic node, and if the first attribute specifies the BLOCK value, determining that the subscriber should not receive a message associated with the topic string of the topic node and topic strings more specific than the topic string of the topic node when the wildcard topic string is less specific than the topic string of the topic node; detecting a generation of a new topic node; and performing the traversing for the new topic node.
-
Specification