Method and System For Providing A Subscription To A Tuple Based On A Variable Identifier

• US 20100161777A1
• Filed: 12/22/2008
• Published: 06/24/2010
• Est. Priority Date: 12/22/2008
• Status: Abandoned Application

• Current Assignee: Scenera Technologies LLC (Scenera Research LLC)
• Original Assignee: Scenera Technologies LLC (Scenera Research LLC)
• Inventors: Morris, Robert P.
• Application Number:
  US12/340,991
• Publication Number:
  US 20100161777A1
• Time in Patent Office: Days
• US Class Current: 709/222
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: H04L 67/54 Presence management, e.g. monitoring or registration for receipt of user log-on information, or the connection status of the users

Abstract

Methods, systems and computer program products are described for providing a subscription to a tuple. In one aspect, a system comprises system components including a subscription profiler component configured to receive subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity, and a tuple identifier evaluator component configured to determine a first tuple identifier by evaluating the tuple identifer expression with the variable set to a first current value stored in the data entity. The system also includes a subscription handler component configured to establish a subscription for the identified subscriber to a first tuple identified by the determined first tuple identifier, and a notification handler component configured to send a first notification message including tuple information from the first tuple to the identified subscriber.

Claims

1. A system for providing a subscription to a tuple, the system comprising system components including:

a subscription profiler component configured to receive subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

a tuple identifier evaluator component configured to determine a first tuple identifier by evaluating the tuple identifer expression with the variable set to a first current value stored in the data entity;

a subscription handler component configured to establish a subscription for the identified subscriber to a first tuple identified by the determined first tuple identifier; and

a notification handler component configured to send a first notification message including tuple information from the first tuple to the identified subscriber,

wherein at least one of the system components includes at least one electronic hardware component.

2. The system of claim 1 wherein the subscriber profiler component is configured to receive the subscription information from at least one of a message sent from a sending client node via a network, a user via a user interface, and configuration data in a local data store.

3. The system of claim 2 wherein the message including the subscription information is formatted according to a publish/subscribe protocol and is at least one of a subscribe message and a publish message.

4. The system of claim 3 wherein the publish/subscribe protocol is a presence protocol.

5. The system of claim 2 wherein the identified subscriber is one of a principal associated with the sending client node from which the subscription information is received, and a principal not associated with the sending client node.

6. The system of claim 1 wherein the tuple identifier evaluator is invoked in response to at least one of receiving the subscription information by the subscription profiler, updating at least one of a specified tuple, changing a value stored in the data entity, and detecting an event based on an attribute of time.

7. The system of claim 1 wherein the data entity is at least one of a contiguous memory region in an accessible memory component, two or more noncontiguous regions in the accessible memory, an element of a tuple, and an element included in a plurality of tuples, and wherein the data entity is configured to store at least one of a simple value, a complex data item, and an attribute of at least one of a tuple and a principal associated with the tuple.

8. The system of claim 1 wherein the tuple identifier expression further includes a selection criterion and the tuple identifier evaluator component is configured to determine the first tuple identifier based on the variable set to a first current value stored in the data entity and the selection criterion.

9. The system of claim 8 wherein the selection criterion is based on at least one of a security interest, a performance indicator, an attribute of a principal, and an attribute of a tuple.

10. The system of claim 1 wherein the tuple identifier evaluator is configured to determine a second tuple identifier by evaluating the tuple identifier expression with the variable set to a second current value stored in the data entity, the subscription handler component is configured to establish a subscription for the identified subscriber to a second tuple identified by the determined second tuple identifier, and the notification handler component is configured to send a second notification message including tuple information from the second tuple to the identified subscriber.

11. A system for providing a subscription to a tuple, the system comprising system components including:

a subscription profiler component configured to receive subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

a service agent component configured to generate a message identifying the tuple identifier expression and the subscriber; and

a protocol service agent component configured to send the message to a publish/subscribe service node configured to host a service for establishing a subscription for the identified subscriber to receive a notification including a current value of a tuple identified based on an evaluation of the tuple identifier expression,

wherein at least one of the system components includes at least one electronic hardware component.

12. The system of claim 11 wherein the subscription profiler component is configured to receive the subscription information from at least one of a message sent from a client node, a message from an application, a user via a user interface, and configuration data in a local data store.

13. The system of claim 11 wherein the generated message including the subscription information is formatted according to a publish/subscribe protocol and is at least one of a subscribe message and a publish message.

14. The system of claim 11 wherein the tuple identifier expression further includes a selection criterion based on at least one of a security interest, a performance indicator, an attribute of a principal, and an attribute of a tuple.

15. The system of claim 11 wherein the message including the subscription information is correlated with another message including tuple information associated with a principal represented by the service agent.

16. The system of claim 11 wherein the identified subscriber is associated with a principal that is different from a principal represented by the service agent.

17. The system of claim 11 further comprising a notification agent component configured to receive a first notification message including first tuple information from a first tuple identified by a first tuple identifier determined by a first evaluation of the expression based on a first current value of the stored data entity assigned to the variable.

18. The system of claim 17 wherein the notification agent component is configured to receive a second notification message including second tuple information from a second tuple identified by a second tuple identifier determined by a second evaluation of the expression based on a second current value of the stored data entity assigned to the variable.

19. A system for providing a subscription to a tuple, the system comprising:

means for receiving subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

means for determining a first tuple identifier by evaluating the tuple identifer expression with the variable set to a first current value stored in the data entity;

means for establishing a subscription for the identified subscriber to a first tuple identified by the determined first tuple identifier; and

means for sending a first notification message including tuple information from the first tuple to the identified subscriber,

wherein at least one of the means includes at least one electronic hardware component.

20. A system for providing a subscription to a tuple, the system comprising:

means for receiving subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

means for generating a message identifying the tuple identifier expression and the subscriber; and

means for sending the message to a publish/subscribe service node configured to host a service for establishing a subscription for the identified subscriber to receive a notification including a current value of a tuple identified based on an evaluation of the tuple identifier expression,

wherein at least one of the means includes at least one electronic hardware component.

21. A method for providing a subscription to a tuple, the method comprising:

receiving subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

determining a first tuple identifier by evaluating the tuple identifer expression with the variable set to a first current value stored in the data entity;

establishing a subscription for the identified subscriber to a first tuple identified by the determined first tuple identifier; and

sending a first notification message including tuple information from the first tuple to the identified subscriber,

wherein at least one of the preceding actions is performed on at least one electronic hardware component.

22. The method of claim 21 wherein the subscription information is received from at least one of a message sent from a sending client node via a network, a user via a user interface, and configuration data in a local data store.

23. The method of claim 22 wherein the message including the subscription information is formatted according to a publish/subscribe protocol and is at least one of a subscribe message and a publish message.

24. The method of claim 23 wherein the publish/subscribe protocol is a presence protocol.

25. The method of claim 22 wherein the identified subscriber is one of a principal associated with the sending client node from which the subscription information is received, and a principal not associated with the sending client node.

26. The method of claim 21 wherein determining the first tuple identifier is in response to at least one of receiving the subscription information, updating at least one of a specified tuple, changing a value stored in the data entity, and detecting an event based on an attribute of time.

27. The method of claim 21 wherein the data entity is at least one of a contiguous memory region in an accessible memory component, two or more noncontiguous regions in the accessible memory, an element of a tuple, and an element included in a plurality of tuples, and wherein the data entity is configured to store at least one of a simple value, a complex data item, and an attribute of at least one of a tuple and a principal associated with the tuple.

28. The method of claim 21 wherein the tuple identifier expression further includes a selection criterion, and wherein determining the first tuple identifier is based on the variable set to a first current value stored in the data entity and the selection criterion.

29. The method of claim 28 wherein the selection criterion is based on at least one of a security interest, a performance indicator, an attribute of a principal, and an attribute of a tuple.

30. The method of claim 21 further comprising:

determining a second tuple identifier by evaluating the tuple identifier expression with the variable set to a second current value stored in the data entity;

establishing a subscription for the identified subscriber to a second tuple identified by the determined second tuple identifier; and

sending a second notification message including tuple information from the second tuple to the identified subscriber.

31. A method for providing a subscription to a tuple, the method comprising:

receiving subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

generating by a service agent representing a principal a message identifying the tuple identifier expression and the subscriber; and

sending by a protocol service agent the message to a publish/subscribe service node configured to host a service for establishing a subscription for the identified subscriber to receive a notification including a current value of a tuple identified based on an evaluation of the tuple identifier expression,

wherein at least one of the preceding actions is performed on at least one electronic hardware component.

32. The method of claim 31 wherein the subscription information is received from at least one of a message sent from a client node, a message from an application, a user via a user interface, and configuration data in a local data store.

33. The method of claim 31 wherein the generated message including the subscription information is formatted according to a publish/subscribe protocol and is at least one of a subscribe message and a publish message.

34. The method of claim 31 wherein the tuple identifier expression further includes a selection criterion based on at least one of a security interest, a performance indicator, an attribute of a principal, and an attribute of a tuple.

35. The method of claim 31 wherein the message including the subscription information is correlated with another message including tuple information associated with the principal represented by the service agent.

36. The method of claim 31 wherein the identified subscriber is associated with a principal that is different from the principal represented by the service agent.

37. The method of claim 31 further comprising receiving a first notification message including first tuple information from a first tuple identified by a first tuple identifier determined by a first evaluation of the expression based on a first current value of the stored data entity assigned to the variable.

38. The method of claim 37 further comprising receiving a second notification message including second tuple information from a second tuple identified by a second tuple identifier determined by a second evaluation of the expression based on a second current value of the stored data entity assigned to the variable.

39. A computer readable medium storing a computer program, executable by a machine, for providing a subscription to a tuple, the computer program comprising executable instructions for:

receiving subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

determining a first tuple identifier by evaluating the tuple identifer expression with the variable set to a first current value stored in the data entity;

establishing a subscription for the identified subscriber to a first tuple identified by the determined first tuple identifier; and

sending a first notification message including tuple information from the first tuple to the identified subscriber.

40. A computer readable medium storing a computer program, executable by a machine, for providing a subscription to a tuple, the computer program comprising executable instructions for:

receiving subscription information identifying a subscriber and identifying a tuple identifier expression including a variable identifying a stored data entity;

generating by a service agent representing a principal a message identifying the tuple identifier expression and the subscriber; and

sending by a protocol service agent the message to a publish/subscribe service node configured to host a service for for establishing a subscription for the identified subscriber to receive a notification including a current value of a tuple identified based on an evaluation of the tuple identifier expression.