Method And System For Performing Data Operations Using A Publish/Subscribe Service
First Claim
1. A method for performing data operations using a publish/subscribe service, the method comprising:
- providing a first tuple that includes data operation information that is configured to operate on a source data;
providing for a first subscription by the first tuple to a second tuple that includes the source data;
providing for a second subscription by a subscriber to the first tuple;
receiving, pursuant to the first subscription, a notification indicating an update of the source data of the second tuple, the notification including the updated source data;
in response to receiving the notification, generating resultant data using the data operation information of the first tuple to process at least the updated source data of the second tuple; and
generating a notify message including the resultant data.
2 Assignments
0 Petitions
Accused Products
Abstract
A method for performing data operations using a publish/subscribe service includes providing a first tuple that includes data operation information that is configured to operate on a source data, providing for a first subscription by the first tuple to a second tuple that includes the source data, and providing for a second subscription by a subscriber to the first tuple. A notification indicating an update of the source data of the second tuple is received pursuant to the first subscription and in response to receiving the notification, resultant data is generated using the data operation information of the first tuple to process at least the updated source data of the second tuple. Thereafter, a notify message including the resultant data is generated.
-
Citations
34 Claims
-
1. A method for performing data operations using a publish/subscribe service, the method comprising:
-
providing a first tuple that includes data operation information that is configured to operate on a source data; providing for a first subscription by the first tuple to a second tuple that includes the source data; providing for a second subscription by a subscriber to the first tuple; receiving, pursuant to the first subscription, a notification indicating an update of the source data of the second tuple, the notification including the updated source data; in response to receiving the notification, generating resultant data using the data operation information of the first tuple to process at least the updated source data of the second tuple; and generating a notify message including the resultant data. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13)
-
-
14. A computer readable medium containing a computer program, executable by a machine, for performing data operations using a publish/subscribe service, the computer program comprising executable instructions for:
-
providing a first tuple that includes data operation information that is configured to operate on a source data; providing for a first subscription by the first tuple to a second tuple that includes the source data; providing for a second subscription by a subscriber to the first tuple; receiving, pursuant to the first subscription, a notification indicating an update of the source data of the second tuple, the notification including the updated source data; in response to receiving the notification, generating resultant data using the data operation information of the first tuple to process at least the updated source data of the second tuple; and generating a notify message including the resultant data. - View Dependent Claims (15, 16, 17, 18, 19, 20, 21, 22)
-
-
23. A system for performing data operations using a publish/subscribe service, the system comprising:
-
a publication handler configured for providing a first tuple that includes data operation information that is configured to operate on a source data; an input watcher component configured for initiating a first subscription by the first tuple to a second tuple that includes the source data and for receiving, pursuant to the first subscription, a notification indicating an update of the source data of the second tuple, the notification including the updated source data; a subscription handler configured for providing for a second subscription by a subscriber to the first tuple; a function executor component configured for generating, in response to receiving the notification, resultant data using the data operation information of the associated first tuple to process at least the updated source data of the second tuple; and a notification handler for generating a notify message including the resultant data. - View Dependent Claims (24, 25, 26, 27, 28, 29, 30, 31, 32, 33)
-
-
34. A system for performing data operations using a publish/subscribe service, the system comprising:
-
means for providing a first tuple that includes data operation information configured to operate on a source data; means for providing for a first subscription by a subscriber to the first tuple; means for initiating a second subscription by the first tuple to a second tuple that includes the source data and for receiving, pursuant to the second subscription, a notification indicating an update of the source data of the second tuple, the notification including the updated source data; means for generating, in response to receiving the notification, resultant data using the data operation information of the associated first tuple to process at least the updated source data of the second tuple; and means for generating a notify message including the resultant data.
-
Specification