Service oriented integration server architecture

• US 7,917,652 B2
• Filed: 02/05/2009
• Issued: 03/29/2011
• Est. Priority Date: 12/17/2003
• Status: Expired due to Term

• Current Assignee: Kyndryl Incorporated (Kyndryl Holdings, Inc.)
• Original Assignee: International Business Machines Corporation
• Inventors: Watt, Stephen James
• Primary Examiner(s): LIN, WEN TAI
• Application Number:
  US12/366,308
• Publication Number:
  US 20090144449A1
• Time in Patent Office: 782 Days
• Field of Search: None
• US Class Current: 709/246
• CPC Class Codes: H04L 69/08 Protocols for interworking; Protocol conversion
• CPC Class Codes: H04L 9/40 Network security protocols

Abstract

An integration server architecture (ISA) that facilitates communication between processes that do not share a common message format or use a common communication protocol. The ISA comprises a combination of adapters and a Queuing and Translation Engine (QTE). Every process that uses the ISA must have an adapter designed to understand that process'"'"'s native message format. The adapter forwards the message to the QTE. The QTE places the forwarded message in an incoming message queue (IMQ). The QTE then retrieves messages from the IMQ in the order they arrive, identifies the sender, and locates an entry for the sender in a Configuration Database (CDB). The CDB entry designates a translation map that enables the QTE to properly translate messages into the receiving process'"'"'s native format. The QTE uses the map to translate the messages into the receiving process'"'"'s native format, and then forwards the translated message to the appropriate adapter.

Claims

1. A system for translating messages sent from a sending process to a receiving process, comprising

one or more processors connected to one or more computer readable storage devices;

first program instructions to receive an incoming message on a communication channel;

second program instructions to retrieve a translation map from a configuration database;

third program instructions to translate the incoming message into an outgoing message using information contained in the translation map; and

fourth program instructions to send the outgoing message on the communication channel;

fifth program instructions to search, responsive to detecting a message in an incoming message queue, the configuration database to locate a gateway profile that matches both the sending process and a target uniform resource locator;

wherein the first through the fifth program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors;

wherein the configuration database stores a plurality of gateway profiles;

wherein each of the plurality of gateway profiles is described using extensible markup language and comprises;

a target uniform resource locator;

a designation of a translation map; and

a designation of a failure queue to which all errors are reported;

wherein the translation map is an extensible style language file.

2. The system of claim 1 further comprising:

sixth program instructions to listen for an incoming message on the communication channel;

wherein the sixth program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors.

3. The system of claim 1 further comprising:

sixth program instructions to listen for the outgoing message on the communication channel;

seventh program instructions to post, responsive to detecting the outgoing message on the communication channel, the outgoing message at a uniform resource locator designated in the outgoing message; and

eighth program instructions to notify the receiving process that the outgoing message is available for retrieval;

wherein the sixth through the eighth program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors.

4. The system of claim 1 further comprising:

sixth program instructions to listen for the outgoing message on the communication channel; and

seventh program instructions to send, responsive to detecting the outgoing message on the communication channel, the outgoing message to the receiving process;

wherein the sixth and seventh program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors.

5. The system of claim 1 further comprising:

sixth program instructions to send a message over the communication channel to an incoming message queue in the one or more transitory computer readable storage devices;

wherein the sixth program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors.

6. The system of claim 5 further comprising:

seventh program instructions to check the incoming message queue for the incoming message, and, responsive to detecting the incoming message in the incoming message queue, retrieve the incoming message from the incoming message queue.

7. The system of claim 5 further comprising:

seventh program instructions to retrieve, responsive to receiving a notice from a processor that the incoming message is in the incoming message queue, the incoming message from the incoming message queue;

wherein the seventh program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors.

8. The system of claim 1 further comprising:

sixth program instructions to listen for an incoming message on the communication channel;

seventh program instructions to send, responsive to detecting an incoming message on the communication channel, the message to an incoming message queue; and

eighth program instructions to notify a processor that the incoming message has been placed in the incoming message queue; and

ninth program instructions to retrieve, responsive to receiving a notice from the processor that the incoming message is in the incoming message queue, the incoming message from the incoming message queue;

wherein the sixth through the eighth program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors.

9. The system of claim 1 further comprising:

sixth program instructions to listen for an incoming message on the communication channel; and

seventh program instructions to send, responsive to detecting an incoming message on the communication channel, the message to an incoming message queue; and

eighth program instructions to retrieve, responsive to placing the incoming message in the incoming message queue,

the incoming message from the incoming message queue;

wherein the sixth through the eighth program instructions are stored in the one or more computer readable storage devices for running by the one or more processors via one or more memories connected to the one or more processors.

10. A computer program product for causing a computer to translate messages sent from a sending process to a receiving process, comprising:

a computer readable storage device;

first program instructions to receive incoming messages on a communication channel;

second program instructions to retrieve a translation map from a configuration database;

third program instructions to translate the incoming message into an outgoing message using information contained in the translation map;

fourth program instructions to send the outgoing message on the communication channel;

wherein the configuration database stores a plurality of gateway profiles;

wherein each of the plurality of gateway profiles is described using extensible markup language and comprises;

a target uniform resource locator;

a designation of the translation map; and

a designation of a failure queue to which all errors are reported;

wherein the translation map is an extensible style language file; and

fifth program instructions to search, responsive to detecting a message in an incoming message queue, the configuration database to locate a gateway profile that matches both the sending process and a target uniform resource locator;

wherein the first through the fifth program instructions are stored in the computer readable storage device.

11. The computer program product of claim 10 further comprising:

sixth program instructions to listen for an incoming message on the communication channel; and

wherein the sixth program instructions are stored in the computer readable storage device.

12. The computer program product of claim 10 further comprising:

sixth program instructions to listen for the outgoing message on the communication channel;

seventh program instructions to post, responsive to detecting the outgoing message on the communication channel, the outgoing message at a uniform resource locator designated in the outgoing message; and

eighth program instructions to notify the receiving process that the outgoing message is available for retrieval;

wherein the sixth through the eighth program instructions are stored in the computer readable storage device.

13. The computer program product of claim 10 further comprising:

sixth program instructions to listen for the outgoing message on the communication channel; and

seventh program instructions to send, responsive to detecting the outgoing message on the communication channel, the outgoing message to the receiving process;

wherein the sixth and seventh program instructions are stored in the computer readable storage device.

14. The computer program product of claim 10 further comprising:

sixth program instructions to send a message over the communication channel to the incoming message queue stored in a computer readable storage medium;

wherein the sixth program instructions are stored in the computer readable storage device.

15. The computer program product of claim 14 further comprising;

seventh instructions to check the incoming message queue for the incoming message, and, responsive to detecting the incoming message in the incoming message queue, retrieve the incoming message from the incoming message queue;

wherein the seventh program instructions are stored in the computer readable storage device.

16. The computer program product of claim 14 further comprising:

seventh program instructions to retrieve, responsive to receiving a notice from a processor that the incoming message is in the incoming message queue, the incoming message from the incoming message queue;

wherein the seventh program instructions are stored in the computer readable storage device.

17. The computer program product of claim 10 further comprising:

sixth program instructions to listen for an incoming message on the communication channel;

seventh program instructions to send, responsive to detecting an incoming message on the communication channel, the message to the incoming message queue; and

eighth program instructions to retrieve

responsive to receiving a notice from a processor that the incoming message is in the incoming message queue, the incoming message from the incoming message queue;

wherein the sixth through the eighth program instructions are stored in the computer readable storage device.

18. The computer readable memory of claim 10 further comprising:

sixth program instructions to listen for an incoming message on the communication channel; and

seventh program instructions to send, responsive to detecting an incoming message on the communication channel, the message to the incoming message queue;

eighth program instructions to retrieve, responsive to placing the incoming message in the incoming message queue;

the incoming message from the incoming message queue;

wherein the sixth through the eighth program instructions are stored in the computer readable storage device.

19. A method of translating messages sent on a communication channel from a sending process to a receiving process, the method comprising:

listening, by a processor, on the communication channel for an incoming message from the sending process;

responsive to detecting an incoming message on the communication channel, retrieving, by the processor, a translation map from a configuration database;

translating, by the processor, the incoming message into an outgoing message using information contained in the translation map; and

sending, by the processor, the outgoing message on the communication channel;

wherein the configuration database stores a plurality of gateway profiles;

wherein each of a plurality of gateway profiles is described using extensible markup language and comprises;

a target uniform resource locator;

a designation of the translation map; and

a designation of a failure queue to which all errors are reported;

wherein the translation map is an extensible style language file; and

wherein when a message translation program detects a message in an incoming message queue, the message translation program searches the configuration database to locate a gateway profile that matches both the sending process and the target uniform resource locator.

20. The method of claim 19 wherein listening, by the processor, on the communication channel for the incoming message from the sending process further comprises placing the incoming message in an incoming message queue;

and retrieving, by the processor, the translation map from the configuration database further comprises retrieving the incoming message from the incoming message queue.