SYSTEMS AND METHODS FOR CLIENT-SIDE FILTERING OF SUBSCRIBED MESSAGES

• US 20080059597A1
• Filed: 10/31/2007
• Published: 03/06/2008
• Est. Priority Date: 02/25/2003
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: BEA Systems Incorporated (Oracle Corporation)
• Inventors: Shafer, John, Blevins, Michael
• Granted Patent: US 7,844,636 B2
• Time in Patent Office: Days
• US Class Current: 709/207
• CPC Class Codes: G06F 2209/547 Messaging middleware
• CPC Class Codes: G06F 2209/548 Queue
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: Y10S 707/99933 Query processing, i.e. searching
• CPC Class Codes: Y10S 707/99943 Generating database or data structure, e.g. via user interface

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.

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.

2. The system of claim 1, wherein the subscription information includes message filters.

3. The system of claim 1, wherein message filters are compared with an extract from the message to determine whether to send the message to a server.

4. The system of claim 3, further comprising a query component on each server, each query component adapted to extract data from a message to be published, whereby the extracted data is compared with the filter value in order to determine whether to send a subscriber the message.

5. The system of claim 4, wherein the query component is an XML query component.

6. A system according to claim 1, wherein:

the message broker component is further adapted to allow subscribers to subscribe to the message channel.

7. A system according to claim 1, further comprising:

a message queue adapted to receive messages on the message channel.

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.

9. The computer readable storage medium of claim 8, wherein the subscription information includes message filters for the servers.

10. The computer readable storage medium of claim 8, wherein message filters are compared with an extract from the message to determine whether to send the message to a server.

11. The computer readable storage medium of claim 10, further comprising a query component on each server, each query component adapted to extract data from a message to be published, whereby the extracted data is compared with the filter value in order to determine whether to send a subscriber the message.

12. The computer readable storage medium of claim 11, wherein the query component is an XML query component.

13. A computer readable storage medium according to claim 8, wherein:

the message broker component is further adapted to allow subscribers to subscribe to the message channel.

14. A computer readable storage medium according to claim 8, further comprising:

a message queue adapted to receive messages on the message channel.