Publish/subscribe data processing with subscription points for customized message processing
First Claim
Patent Images
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.
3 Assignments
0 Petitions
Accused Products
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.
-
Citations
6 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. - View Dependent Claims (2, 3, 4)
-
-
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.- View Dependent Claims (6)
-
Specification