Multi-standard message processing

• US 10,284,515 B2
• Filed: 06/08/2017
• Issued: 05/07/2019
• Est. Priority Date: 06/08/2017
• Status: Active Grant

• Current Assignee: Amadeus S.A.S. (Amadeus Global Travel Distribution S.A.)
• Original Assignee: Amadeus S.A.S. (Amadeus Global Travel Distribution S.A.)
• Inventors: Zhang, Yizhen, Campora, Simone, Marchand, Ivan Xavier, Fontolliet, Loic
• Primary Examiner(s): Nguyen, Phuoc H
• Application Number:
  US15/617,180
• Publication Number:
  US 20180359210A1
• Time in Patent Office: 698 Days
• Field of Search: 709206
• CPC Class Codes: G09B 21/009 Teaching or communicating with deaf persons G09B21/04 takes precedence; deaf and dumb persons G09B21/00
• CPC Class Codes: H04L 51/56 Unified messaging, e.g. interactions between e-mail, instant messaging or converged IP messaging [CPM]
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/131 Protocols for games, networked simulations or virtual reality

Abstract

Messages are processed in a distributed messaging system by a message processing engine. Message targets operates according to a first standard or a second legacy standard. In response to receiving a database commit indication, a message envelope is generated for each message target to be notified operating according to the first standard and at least one messages within each message envelope. Message envelope dependencies between generated message envelopes for a same message target are computed. Message dependencies between the messages within each message envelope are computed based at least on the standard of the messages of the respective message envelope and functions of the messages. The messages are sent to the respective message target in a sequence based on the message envelope dependencies and the message dependencies.

Claims

1. A method for processing messages in a distributed messaging system with a plurality of message targets, wherein at least one message target of the plurality of message targets operates according to a first standard and at least one message target of the plurality of message targets operates according to a second legacy standard, the method comprising:

receiving, by a message processing engine, a plurality of database commit indications, each database commit indication indicating a change of a database record;

in response to receiving a database commit indication of the plurality of database commit indications, generating, by the message processing engine, a message envelope for each message target to be notified operating according to the first standard and at least one message within each message envelope;

computing, by the message processing engine, message envelope dependencies between generated message envelopes for a same message target, the message envelope dependencies defining an order of the message envelopes for the same message target;

computing, by the message processing engine, message dependencies between the messages within each message envelope based at least on the standard of the messages of the respective message envelope and functions of the messages, the message dependencies defining an order of the messages within each message envelope; and

sending the messages from the message processing engine to the respective message target in a sequence based on the message envelope dependencies and the message dependencies.

2. The method of claim 1 further comprising:

in response to receiving a first database commit indication of the plurality of database commit indications from a database system operating according to the first standard, generating a message envelope for each message target to be notified.

3. The method of claim 2 further comprising:

generating at least one message within each message envelope.

4. The method of claim 3 wherein generating the at least one message within each message envelope further comprises:

generating a first message envelope with a plurality of interdependent first messages to be relayed to a first message target operating according to the first standard, wherein the plurality of interdependent first messages is specified in accordance with the first standard; and

generating one second message to be relayed to a second message target operating according to the second legacy standard, wherein the second message is specified in accordance with the second legacy standard.

5. The method of claim 4 further comprising:

computing the message envelope dependencies between the first message envelope and other message envelopes already pending for the first message target, the envelope dependencies defining the order of the message envelopes for the first message target;

computing the message dependencies between the first messages of the first message envelope based at least on the first message target and the functions of the first messages, the message dependencies defining the order of the messages within each message envelope; and

sending the first messages to the first message target in a sequence based on the message envelope dependencies and the message dependencies.

6. The method of claim 4 further comprising:

in response to receiving a second database commit indication of the plurality database commit indications from a legacy database system operating according to the second standard, generating a third message for each message target to be notified, wherein the third message is a message according to the second legacy standard; and

sending the third message without computing a message dependency for the third message in response to determining that no other message is pending to be sent to the message target of the third message.

7. The method of claim 4 further comprising:

in response to receiving a second database commit indication of the plurality database commit indications from a legacy database system operating according to the second standard, generating a third message for each message target to be notified, wherein the third message is a message according to the second legacy standard; and

in response to determining that at least one other message is pending to be sent to the message target of the third message, computing the message dependency of the third message based at least on the message target and the function of the third message, the message dependencies defining the order of the messages for the message target of the third message and sending the at least one other message and the third message to the message target of the third message in a sequence based on the message envelope dependencies and the message dependencies.

8. The method of claim 1 comprising:

assigning, for each message envelope, a given priority value to each of the plurality of interdependent messages depending at least on the standard of the message and a message type; and

computing the message dependency between the messages with each message envelope based on the assigned priority values.

9. The method of claim 1 comprising:

sending a message in response to determining that the message is independent from any other message within the message envelope of the message and the message envelope of the message is independent from any other message envelope.

10. The method of claim 9 further comprising:

updating the message dependency of the message sent and the message dependency of the next message, if any, within the order of the message within the message envelope of the message.

11. The method of claim 9 further comprising:

updating the message envelope dependency of the message envelope of the message sent and updating the envelope dependency of the next message envelope, if any, in the order of message envelopes in response to determining that the message sent was the last message in the order of messages within the message envelope of the message sent.

12. A system for processing messages in a distributed messaging system with a plurality of message targets, wherein at least one message target of the plurality of message targets operates according to a first standard and at least one message target of the plurality of message targets operates according to a second legacy standard, the message processing system comprising:

one or more processors; and

a memory coupled to the one or more processors, the memory storing program code that, when executed by the one or more processors, cause the system to;

receive a plurality of database commit indications, each database commit indication indicating a change of a database record;

in response to receiving a database commit indication of the plurality of database commit indications, generate a message envelope for each message target to be notified operating according to the first standard and at least one message within each message envelope;

compute message envelope dependencies between generated message envelopes for a same message target, the message envelope dependencies defining an order of the message envelopes for the same message target;

compute message dependencies between the messages within each message envelope based at least on the standard of the messages of the respective message envelope and functions of the messages, the message dependencies defining an order of the messages within each message envelope; and

send the messages to the respective message target in a sequence based on the message envelope dependencies and the message dependencies.

13. The system of claim 12 wherein the program code further causes the system to:

in response to receiving a first database commit indication of the plurality database commit indications from a database system operating according to the first standard, generate a message envelope for each message target to be notified.

14. The system of claim 13 wherein the program code further causes the system to:

generate at least one message within each message envelope.

15. The system of claim 14 wherein the instructions upon execution cause the message processing system to generate the at least one message within each message envelope by causing the message handling system to:

generate a first message envelope with a plurality of interdependent first messages to be relayed to a first message target operating according to the first standard, wherein the plurality of interdependent first messages is specified in accordance with the first standard; and

generate one second message to be relayed to a second message target operating according to the second legacy standard, wherein the second message is specified in accordance with the second legacy standard.

16. The system of claim 15 wherein the program code further causes the system to:

compute the message envelope dependencies between the first message envelope and other message envelopes already pending for the first message target, the envelope dependencies defining the order of the message envelopes for the first message target;

compute the message dependencies between the first messages of the first message envelope based at least on the first message target and the functions of the first messages, the message dependencies defining the order of the messages within each message envelope; and

send the first messages to the first message target in a sequence based on the message envelope dependencies and the message dependencies.

17. The system of claim 15 wherein the program code further causes the system to:

in response to receiving a second database commit indication of the plurality database commit indications from a legacy database system operating according to the second standard, generate a third message for each message target to be notified, wherein the third message is a message according to the second legacy standard; and

send the third message without computing a message dependency for the third message in response to determining that no other message is pending to be sent to the message target of the third message.

18. The system of claim 15 wherein the program code further causes the system to:

in response to receiving a second database commit indication of the plurality database commit indications from a legacy database system operating according to the second standard, generate a third message for each message target to be notified, wherein the third message is a message according to the second legacy standard; and

in response to determining that at least one other message is pending to be sent to the message target of the third message, compute the message dependency of the third message based at least on the message target and the function of the third message, the message dependencies defining the order of the messages for the message target of the third message and sending the at least one other message and the third message to the message target of the third message in a sequence based on the message envelope dependencies and the message dependencies.

19. The system of claim 12 wherein the program code further causes the system to:

assign, for each message envelope, a given priority value to each of the plurality of interdependent messages depending at least on the standard of the message and a message type; and

compute the message dependency between the messages with each message envelope based on the assigned priority values.

20. The system of claim 12 wherein the program code further causes the system to:

send a message in response to determining that the message is independent from any other message within the message envelope of the message and the message envelope of the message is independent from any other message envelope.

21. The system of claim 20 wherein the program code further causes the system to:

update the message dependency of the message sent and the message dependency of the next message, if any, within the order of the message within the message envelope of the message.

22. The system of claim 20 wherein the program code further causes the system to:

update the message envelope dependency of the message envelope of the message sent and updating the envelope dependency of the next message envelope, if any, in the order of message envelopes in response to determining that the message sent was the last message in the order of messages within the message envelope of the message sent.

23. A computer program product for processing messages in a distributed messaging system with a plurality of message targets, wherein at least one message target of the plurality of message targets operates according to a first standard and at least one message target of the plurality of message targets operates according to a second legacy standard, the computer program product comprising:

a non-transitory computer-readable storage medium; and

program code stored on the non-transitory computer-readable storage medium that, when executed by one or more processors, causes the one or more processors to;

receive a plurality of database commit indications, each database commit indication indicating a change of a database record;

in response to receiving a database commit indication of the plurality of database commit indications, generate a message envelope for each message target to be notified operating according to the first standard and at least one message within each message envelope;

compute message envelope dependencies between generated message envelopes for a same message target, the message envelope dependencies defining an order of the message envelopes for the same message target;

compute message dependencies between the messages within each message envelope based at least on the standard of the messages of the respective message envelope and functions of the messages, the message dependencies defining an order of the messages within each message envelope; and

send the messages to the respective message target in a sequence based on the message envelope dependencies and the message dependencies.