Method And System For Providing A Subscription To A Tuple Based On A Schema Associated With The Tuple

• US 20090307374A1
• Filed: 06/05/2008
• Published: 12/10/2009
• Est. Priority Date: 06/05/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/133,630
• Publication Number:
  US 20090307374A1
• Time in Patent Office: Days
• US Class Current: 709/246
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• 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
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

Methods, systems and computer program products are described for providing a subscription to a tuple based on a schema associated with the tuple. In one aspect, a system includes a message router component configured for receiving a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple. The system also includes a conformance detector component configured for determining a conforming tuple, where at least a portion of the conforming tuple conforms to the identified schema, and a subscription handler component configured for establishing for the identified principal a subscription to the conforming tuple based on the subscription information.

Claims

1. A system for providing a subscription to a tuple based on a schema associated with the tuple, the system comprising:

a message router component configured for receiving a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple;

a conformance detector component configured for determining a conforming tuple, wherein at least a portion of the conforming tuple conforms to the identified schema; and

a subscription handler component configured for establishing for the identified principal a subscription to the conforming tuple based on the subscription information.

2. The system of claim 1 wherein the message is formatted according to at least one of a publish-subscribe protocol and an event notification protocol, and wherein the message is at least one of a subscribe message, a publish message and a notification message.

3. The system of claim 2 wherein the publish-subscribe protocol is a presence protocol.

4. The system of claim 1 wherein the identified principal is represented by at least one of a client node sending the message and a principal represented by another client node.

5. The system of claim 1 wherein the schema is at least partially specified in the subscription information.

6. The system of claim 1 wherein the subscription information further includes a search criteria.

7. The system of claim 1 wherein the conformance detector component is further configured for validating at least a portion of at least one of an updated tuple and a newly created tuple according to the identified schema to determine that at least a portion of the tuple conforms to the identified schema.

8. The system of claim 1 wherein the subscription handler component is further configured for at least one of adding an identifier associated with the identified principal to a subscription list associated with the conforming tuple;

and adding an identifier associated with the identified principal to a subscription list of a proxy tuple associated with at least one of the received message and the identified principal, and adding an identifier associated with the proxy tuple to a subscription list of the conforming tuple.

9. The system of claim 1 further including a notification handler component configured for generating a notification including at least a portion of the conforming tuple in a notification message, wherein the notification message is associated with a subscription in a subscription list of at least one of the conforming tuple and a proxy tuple associated with at least one of the received message and the identified principal.

10. The system of claim 1 further including a notification handler component configured for sending a notification message to the identified principal when the conforming tuple is updated, the notification message including at least a portion of the conforming tuple.

11. The system of claim 1 further including a publication handler component for updating the conforming tuple so that the updated tuple no longer conforms to the identified schema, and wherein the subscription handler component is further configured for maintaining the subscription to the updated nonconforming tuple.

12. The system of claim 1 further including a publication handler component for updating the conforming tuple so that the updated tuple no longer conforms to the identified schema, and wherein the subscription handler component is further configured for terminating the subscription to the updated nonconforming tuple.

13. A system for providing a subscription to a tuple based on a schema associated with the tuple, the system comprising:

a publish-subscribe agent configured for generating a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple; and

a protocol interface component configured for sending the message to a service node for establishing for the identified principal a subscription to a conforming tuple managed by the service node, wherein at least a portion of the conforming tuple conforms to the identified schema.

14. The system of claim 13 further including a watcher user agent component configured for receiving a notification message in response to sending the message, the notification message including a current value of an element of the conforming tuple.

15. The system of claim 13 wherein the identified principal is represented by at least one of a client node sending the message and a principal represented by another client node.

16. The system of claim 13 wherein the message is formatted according to at least one of a publish-subscribe protocol and an event notification protocol, and wherein the message is at least one of a subscribe message, a publish message and a notification message.

17. The system of claim 13 wherein the schema is at least partially specified in the subscription information.

18. The system of claim 13 wherein the subscription information further includes a search criteria.

19. A method for providing a subscription to a tuple based on a schema associated with the tuple, the method comprising:

generating a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple; and

sending the message to a service node for establishing for the identified principal a subscription to a conforming tuple managed by the service node, wherein at least a portion of the conforming tuple conforms to the identified schema.

20. The method of claim 19 further including receiving a notification message in response to sending the message, the notification message including a current value of an element of the conforming tuple.

21. The method of claim 19 wherein the identified principal is represented by at least one of a client node sending the message and a principal represented by another client node.

22. The method of claim 19 wherein the message is formatted according to at least one of a publish-subscribe protocol and an event notification protocol, and wherein the message is at least one of a subscribe message, a publish message and a notification message.

23. The method of claim 19 wherein the subscription information further includes a search criteria.

24. A method for providing a subscription to a tuple based on a schema associated with the tuple, the method comprising:

receiving a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple;

determining a conforming tuple, wherein at least a portion of the conforming tuple conforms to the identified schema; and

establishing for the identified principal a subscription to the conforming tuple based on the subscription information.

25. The method of claim 24 wherein the message is formatted according to at least one of a publish-subscribe protocol and an event notification protocol, and wherein the message is at least one of a subscribe message, a publish message and a notification message.

26. The method of claim 24 wherein the publish-subscribe protocol is a presence protocol.

27. The method of claim 24 wherein the identified principal is represented by at least one of a client node sending the message and a principal represented by another client node.

28. The method of claim 24 wherein the schema is at least partially specified in the subscription information.

29. The method of claim 24 wherein the subscription information further includes a search criteria.

30. The method of claim 24 wherein determining the conforming tuple includes searching a tuple data store.

31. The method of claim 24 further comprising:

receiving a message for one of creating a new tuple and updating an existing tuple; and

validating at least a portion of the updated tuple or the new tuple according to the identified schema to determine that at least a portion of the updated tuple or the new tuple conforms to the identified schema.

32. The method of claim 24 wherein establishing the subscription includes at least one of:

adding an identifier associated with the identified principal to a subscription list associated with the conforming tuple; and

adding an identifier associated with the identified principal to a subscription list of a proxy tuple associated with at least one of the received message and the identified principal, and adding an identifier associated with the proxy tuple to a subscription list of the conforming tuple.

33. The method of claim 24 further including sending a notification including at least a portion of the conforming tuple in a notification message, wherein the notification message is associated with a subscription in a subscription list of at least one of the conforming tuple and the identified principal.

34. The method of claim 24 further including sending a notification message to the identified principal when the conforming tuple is updated, the notification message including at least a portion of the conforming tuple.

35. The method of claim 24 further including updating the conforming tuple so that the updated tuple no longer conforms to the identified schema, and maintaining the subscription to the updated tuple.

36. The method of claim 24 further including updating the conforming tuple so that the updated tuple no longer conforms to the identified schema, and terminating the subscription to the updated tuple.

37. A computer readable medium containing a computer program, executable by a machine, for providing a subscription to a tuple based on a schema associated with the tuple, the computer program comprising executable instructions for:

receiving a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple;

determining a conforming tuple, wherein at least a portion of the conforming tuple conforms to the identified schema; and

establishing for the identified principal a subscription to the conforming tuple based on the subscription information.

38. A computer readable medium containing a computer program, executable by a machine, for providing a subscription to a tuple based on a schema associated with the tuple, the computer program comprising executable instructions for:

generating a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple; and

sending the message to a service node for establishing for the identified principal a subscription to a conforming tuple managed by the service node, wherein at least a portion of the conforming tuple conforms to the identified schema.

39. A system for providing a subscription to a tuple based on a schema associated with the tuple, the system comprising:

means for receiving a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple;

means for determining a conforming tuple, wherein at least a portion of the conforming tuple conforms to the identified schema; and

means for establishing for the identified principal a subscription to the conforming tuple based on the subscription information.

40. A system for providing a subscription to a tuple based on a schema associated with the tuple, the system comprising:

means for generating a message identifying a principal and including subscription information identifying a schema that specifies a set of constraints that defines a structure and vocabulary of a conforming tuple; and

means for sending the message to a service node for establishing for the identified principal a subscription to a conforming tuple managed by the service node, wherein at least a portion of the conforming tuple conforms to the identified schema.