Model driven message processing

• US 20070180151A1
• Filed: 09/20/2005
• Published: 08/02/2007
• Est. Priority Date: 09/20/2005
• Status: Abandoned Application

• Current Assignee: Honeywell International Inc.
• Original Assignee: Honeywell International Inc.
• Inventors: Richardson, James, Dietz, Mark, Schewe, Jon
• Application Number:
  US11/231,006
• Publication Number:
  US 20070180151A1
• Time in Patent Office: Days
• US Class Current: 709/248
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: H04L 67/12 specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks

Abstract

Systems and methods for model driven message processing are provided. In one embodiment, a method for propagating information object updates is provided. The method comprises logging a sequence of update requests made to a local information object by one or more applications, correlating the sequence of update requests with one or more message formats based on message semantics defined by a message model, encoding the sequence of update requests as one or more messages based on application-layer message formats defined by the message model, and communicating the one or more messages to one or more remote computer systems.

Claims

1. An information object replication system, the system comprising:

a log adapted to store records;

a request logging function adapted to record a sequence of updates sent by one or more local applications to a local information object in the log; and

an update propagation function in communication with the log, the update propagation function adapted to communicate one or more messages to one or more remote information objects, wherein the one or more messages represent updates to the local information object based on the sequence of updates, the update propagation function is further adapted to generate the one or more messages based on application-layer message formats and message semantics defined by a message model.

2. The system of claim 1, wherein the update propagation function is adapted to evaluate the contents of the log and correlate the sequence of updates recorded in the log with the one or more messages based on the message semantics.

3. The system of claim 2, wherein the update propagation function is further adapted to correlate the sequence of updates with the one or more messages based on the satisfaction of one or more preconditions defined by the message semantics.

4. The system of claim 3, wherein the update propagation function is further adapted to determine if the one or more preconditions is satisfied by referencing one or both of the local information object, and the sequence of updates.

5. The system of claim 1, wherein the update propagation function determines which source object states to propagate to the one or more destination objects based on information quality of service accuracy requirements.

6. The system of claim 1, wherein the update propagation function applies a compression algorithm that transforms the sequence of requests from the request logging function into a compressed sequence of requests.

7. The system of claim 1, further comprising:

an update reception function, wherein the update reception function is adapted to output a second sequence of updates to the local information object based on a message received from a remote computer system.

8. The system of claim 7, wherein the update reception function correlates the message received from a remote computer system with the second sequence of updates based on the application-layer message formats and message semantics defined by the message model.

9. The system of claim 8, wherein the update reception function is further adapted to correlate the message received from a remote computer system with the second sequence of updates based on the satisfaction of one or more preconditions defined by the message semantics.

10. A method for propagating information object updates, the method comprising:

logging a sequence of update requests made to a local information object by one or more applications;

correlating the sequence of update requests with one or more message formats based on message semantics defined by a message model;

encoding the sequence of update requests as one or more messages based on application-layer message formats defined by the message model; and

communicating the one or more messages to one or more remote computer systems.

11. The method of claim 10, further comprising:

correlating the sequence of updates with the message format based on satisfying one or more preconditions defined by the message semantics.

12. The method of claim 11, further comprising:

determining if the one or more preconditions are satisfied by referencing one or both of the local information object, and the sequence of updates.

13. The method of claim 10, further comprising:

applying a compression algorithm that transforms the sequence of update requests into a compressed sequence of update requests.

14. The method of claim 10, wherein communicating the one or more messages further comprises timing the propagation of the one or more messages to the one or more remote computer systems based on one or both of information quality of service accuracy requirements and information quality of service freshness requirements.

15. The method of claim 10, wherein when the messaging model identifies multiple ways to encode the sequence of update requests as one or more messages, encoding the sequence of update requests further comprises:

choosing the one or more messages that result in a least cost encoding.

16. The method of claim 10, further comprising:

receiving a message at a first remote computer system of the one or more remote computer systems;

correlating the message received with a second sequence of updates based on the application-layer message formats and message semantics defined by the message model; and

outputting the second sequence of updates to a remote information object.

17. The method of claim 10, further comprising:

correlating the message received with a second sequence of updates based on satisfying one or more preconditions defined by the message semantics.

18. The method of claim 10, further comprising:

receiving a message from a first remote computer system of the one or more remote computer systems;

correlating the message received from the first remote computer system with a second sequence of updates based on the application-layer message formats and message semantics defined by the message model; and

outputting the second sequence of updates to the local information object.

19. The method of claim 18, further comprising:

generating computer-executable instructions for performing one or more of the logging a sequence of update requests, the correlating the sequence of update requests, the encoding the sequence of update requests, the communicating the one or more messages, the receiving a message, the correlating the message received and the outputting the second sequence of updates, based on the messaging model.

20. The method of claim 18 further comprising:

correlating the message received from the first remote computer system with a second sequence of updates based on satisfying one or more preconditions defined by the message semantics.

21. A computer-readable medium having computer-executable instructions for performing a method for propagating information object updates, the method comprising:

logging a sequence of update requests made to a local information object by one or more applications;

correlating the sequence of update requests with one or more message formats based on message semantics defined by a message model;

encoding the sequence of update requests as one or more messages based on application-layer message formats defined by the message model; and

communicating the one or more messages to one or more remote computer systems.

22. The computer-readable medium of claim 21, further comprising:

correlating the sequence of updates with the message format based on satisfying one or more preconditions defined by the message semantics.

23. The computer-readable medium of claim 22, further comprising:

determining if the one or more preconditions are satisfied by referencing one or both of the local information object, and the sequence of updates.

24. The computer-readable medium of claim 21, further comprising:

applying a compression algorithm that transforms the sequence of update requests into a compressed sequence of update requests.

25. The computer-readable medium of claim 21, wherein communicating the one or more messages further comprises timing the propagation of the one or more messages to the one or more remote computer systems based on one or both of information quality of service accuracy requirements and information quality of service freshness requirements.

26. The computer-readable medium of claim 21, wherein when the messaging model identifies multiple way to encode the sequence of update requests as one or more messages, encoding the sequence of update requests further comprises:

choosing the one or more messages that result in a least cost encoding.

27. The computer-readable medium of claim 21, further comprising:

receiving a message from a first remote computer system of the one or more remote computer systems;

correlating the message received from the first remote computer system with a second sequence of updates based on the application-layer message formats and message semantics defined by the message model; and

outputting the second sequence of updates to the local information object.

28. The computer-readable medium of claim 27, wherein the computer-executable instructions are generated by one or more automated software generation tools based on the messaging model.

29. An information object replication system, the system comprising:

means for logging a sequence of update requests made to a local information object by one or more applications;

means for correlating the sequence of update requests with one or more message formats based on message semantics defined by a message model, the means for correlating responsive to the means for logging;

means for encoding the sequence of update requests as one or more messages based on application-layer message formats defined by the message model, the means for encoding responsive to the means for correlation; and

means for communicating the one or more messages to one or more remote computer systems, the means for communicating responsive to the means for encoding.

30. The system of claim 29, further comprising:

means for receiving a message from a first remote computer system of the one or more remote computer system;

means for correlating the message received from the first remote computer system with a second sequence of updates based on the application-layer message formats and message semantics defined by the message model, the means for correlating responsive to the means for receiving; and

means for updating the local information object based on the second sequence of updates, the means for updating responsive to the means for correlating.