Systems and methods for client-side filtering of subscribed messages

• US 7,844,636 B2
• Filed: 10/31/2007
• Issued: 11/30/2010
• Est. Priority Date: 02/25/2003
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Shafer, John C., Blevins, Michael
• Primary Examiner(s): Mofiz; Apu M
• Assistant Examiner(s): Nguyen; Cindy
• Application Number:
  US11/932,176
• Publication Number:
  US 20080059597A1
• Time in Patent Office: 1,126 Days
• Field of Search: 709/207, 709/203, 709/206, 707/2, 707/799
• US Class Current: 707/799
• 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 that enables the servers to publish messages to a message channel and to subscribe to receiving messages on said message channel;

the message broker associated with a cache memory and a database to determine routing,

wherein the message broker checks whether the servers are capable of registering for a dynamic subscription to the message channel, wherein the dynamic subscription can change at runtime, and wherein if the servers are capable of registering for said dynamic subscription, the message broker accesses the database to get subscription information, otherwise if the servers are not capable of registering for said dynamic subscription, the message broker accesses 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 having a set of instructions stored thereon, which when executed by one or more processors, cause said one or more processors to implement:

a message broker component that enables the servers to publish messages to a message channel and to subscribe to receiving messages on said message channel;

the message broker associated with a cache memory and a database to determine routing,

wherein the message broker checks whether the servers are capable of registering for a dynamic subscription to the message channel, wherein the dynamic subscription can change at runtime, and wherein if the servers are capable of registering for said dynamic subscription, the message broker accesses the database to get subscription information, otherwise if the servers are not capable of registering for said dynamic subscription, the message broker accesses 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.