SYSTEMS AND METHODS FOR CLIENT-SIDE FILTERING OF SUBSCRIBED MESSAGES
First Claim
1. A system for filtering messages between servers on a message channel, comprising:
- a message broker component adapted to publish messages to a message channel;
the message broker associated with a cache memory and a database to determine routing, wherein the message broker checks whether any of the servers is capable of doing a dynamic subscription to the message channel, if so, the message broker accesses the database to get subscription information, if not the message broker access the cache memory to get the subscription information.
1 Assignment
0 Petitions
Accused Products
Abstract
A message broker can allow any server in a cluster to publish to, and subscribe, to a message channel. A server subscribing to a channel can set up a message filter such that XQuery expressions can be used to filter against the messages arriving on the channel A message broker can also utilize a unique filtering algorithm to optimize data access. Static subscription information can be captured in order for a message broker to do client-side filtering. A message broker can also construct and maintain at least one table in memory that indicates whether any server in the cluster may ever do a dynamic subscription. For dynamic subscriptions, the publishing server can extract the information from a database, such as by executing a DBMS select on a subscription table using a primary key lookup.
-
Citations
14 Claims
-
1. A system for filtering messages between servers on a message channel, comprising:
-
a message broker component adapted to publish messages to a message channel;
the message broker associated with a cache memory and a database to determine routing,wherein the message broker checks whether any of the servers is capable of doing a dynamic subscription to the message channel, if so, the message broker accesses the database to get subscription information, if not the message broker access the cache memory to get the subscription information. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A computer readable storage medium comprising:
a message broker component adapted to publish messages to a message channel;
the message broker associated with a cache memory and a database to determine routing, wherein the message broker checks whether any of the servers is capable of doing a dynamic subscription to the message channel, if so, the message broker accesses the database to get subscription information, if not the message broker access the cache memory to get the subscription information.- View Dependent Claims (9, 10, 11, 12, 13, 14)
Specification