US 6,643,682 B1Granted

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

AssigneeInternational Business Machines Corporation

InventorsStephen James Paul Todd, Malcolm David Ayres, Timothy Nicholas Holloway, Simon Anthony James Holdsworth, Marc-Thomas Schmidt, Michael George Taylor

Life of this patent

Estimating the term…

patentgrep

Loading patent…

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.

Claims6

Dependent claims

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.

10 more elements

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.

9 more elements

Dependencies are inferred from the claim text.