Publish/subscribe data processing with subscription points for customized message processing

• US 6,643,682 B1
• Filed: 02/22/2000
• Issued: 11/04/2003
• Est. Priority Date: 09/28/1999
• Status: Expired due to Term

• Current Assignee: Google LLC (Alphabet Inc.)
• Original Assignee: International Business Machines Corporation
• Inventors: Taylor, Michael George, Todd, Stephen James Paul, Schmidt, Marc-Thomas, Ayres, Malcolm David, Holloway, Timothy Nicholas, Holdsworth, Simon Anthony James
• Primary Examiner(s): Wiley, David
• Assistant Examiner(s): DELGADO, MICHAEL A
• Application Number:
  US09/510,465
• Time in Patent Office: 1,351 Days
• Field of Search: 709/204, 709/225, 709/231, 709/238, 709/241, 709/318, 709/202, 707/3, 707/10, 700/128
• US Class Current: 709/202
• CPC Class Codes: G06F 16/9535 Search customisation based on user profiles and personalisation
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

A message broker data processing apparatus has a unit for receiving published messages on a topic from a publisher application; a unit for processing the received messages; and a unit for distributing the processed messages to subscriber applications; wherein the unit for distributing includes a plurality of subscription point data processing nodes, a first subscription point data processing node distributes messages to a subscriber application which has previously registered a subscription request identifying the first subscription point data processing node with the broker apparatus.

Claims

1. A message broker data processing apparatus comprising:

means for receiving published messages on a topic from a publisher application;

means for processing the received messages; and

means for distributing the processed messages to subscriber applications;

wherein the means for distributing includes a plurality of subscription point data processing nodes, a first subscription point data processing node distributes messages to a first subscriber application which has previously registered a subscription request identifying the first subscription point data processing node and identifying said topic With the broker apparatus, and a second subscription point data processing node distributes messages to a second subscriber application which has previously registered a subscription request identifying the second subscription point data processing node and identifying said topic with the broker application;

wherein said first subscription point data processing node receives the published messages before the published messages have been processed by the means for processing and said second subscription point data processing node receives the published messages after the published messages have been processed by the means for processing; and

wherein the means for processing includes at least one message flow data processing node which performs a specific data processing operation; and

wherein the apparatus further comprises;

means for performing a detection that no subscriber application has registered a subscription request identifying a particular subscription point data processing node with the broker apparatus; and

means for, in response to the detection that no subscriber application has registered a subscription request identifying a particular subscription point data processing apparatus, disabling the execution of a message flow data processing node which is uniquely associated with the particular subscription point data processing node.

2. The apparatus of claim 1 wherein said apparatus communicates with a subscriber application over the Internet and wherein at least one of the subscriber applications and the publisher application runs in conjunction with a World Wide Web browser.

3. The apparatus of claim 1 wherein at least one of the message flow data processing nodes is a message transformation node.

4. The apparatus of claim 1 further wherein the means for disabling disables each message flow data processing node which is uniquely associated with the particular subscription point data processing node.

5. A message broker data processing method comprising steps of:

(a) receiving published messages on a topic from a publisher application;

(b) processing the received messages; and

(c) distributing the processed messages to subscriber applications;

wherein the distributing step involves a plurality of subscription point data processing nodes, a first subscription point data processing node distributes messages to a first subscriber application which has previously registered a subscription request identifying the first subscription point data processing node and identifying said topic with the broker, and a second subscription point data processing node distributes messages to a second subscriber application which has previously registered a subscription request identifying the second subscription point data processing node and identifying said topic with the broker;

wherein said first subscription point data processing node receives the published messages before the published messages have been processed at step (b)and said second subscription point data processing node receives the published messages after the published messages have been processed at step (b); and

wherein the processing step involves at least one message flow data processing node which performs a specific data processing operation; and

wherein the method further comprises steps of;

performing a detection that no subscriber application has registered a subscription request identifying a particular subscription point data processing node with the broker; and

in response to the detection that no subscriber application has registered a subscription request identifying a particular subscription point data processing node, disabling the execution associated with the particular subscription point data processing node.

6. A computer program product, stored on a computer readable storage medium for, when run on a computer system, instructing the computer system to carry out the method of claim 5.