Integration engine for communications between source and target applications

Patent metadata

Field	Value
Publication number	US-9871848-B1
Application number	US-201314040826-A
Country	US
Kind code	B1
Filing date	Sep 30, 2013
Priority date	Sep 30, 2013
Publication date	Jan 16, 2018
Grant date	Jan 16, 2018

Abstract

An integration engine is provided for communications between source and target applications. A message is sent from a source application to a target application, by processing a header element to route the message to the target application; transforming a message format of the message to a different message format; storing the message payload using a Claim-Check Enterprise Application Integration (EAI) pattern; and providing the transformed message to the target application. Transport adapters optionally transform a message format of the message to a different message format, such as a message format of the source application being transformed to a message format of the target application. The header element is optionally updated using a channel interceptor to update a next endpoint in a flow based on one or more business rules applied to the message payload. The header element can be processed by a header-based router that routes the message to a next endpoint in a flow. The exemplary integration engine is based on a Spring Integration Framework.

First claim

What is claimed is:

1. A method for sending a message from a source application to a target application, said message comprising a message payload and a header element comprising routing information, said method comprising:
processing said header element, using at least one processing device of an integration engine, to route said message to said target application;
transforming, using said at least one processing device of said integration engine, a message format of said message to a different message format to change a message format of said source application to a message format of said target application;
storing, using said at least one processing device of said integration engine, said message payload using a claim-Check Enterprise Application Integration (EAI) pattern;
applying, using said at least one processing device of said integration engine, one or more business rules to said message payload to dynamically change a next endpoint in said header element for said message; and
providing, using said at least one processing device of said integration engine, said transformed message to said target application.

2. The method of claim 1 wherein said step of storing said message payload using said claim-Check EAI pattern reduces a data volume of said message.

3. The method of claim 1 wherein said step of transforming a message format of said message to a different message format employs one or more transport adapters.

4. The method of claim 3 wherein said message format of said message comprises one or more of Java Message Services (JMS), Hypertext Transfer Protocol (http), File Transfer Protocol (FTP), Transmission Control Protocol (TCP), Remote Method Invocation (RMI), Internet Interoperable Protocol (HOP) and User Datagram Protocol (UDP).

5. The method of claim 1 further comprising the step of updating said routing information of said header element using a channel interceptor.

6. The method of claim 5 wherein said channel interceptor updates said next endpoint of said routing information in said flow based on said one or more business rules applied to said message payload.

7. The method of claim 1 wherein said header element is processed by a header-based router that routes said message to a next endpoint in a flow.

8. The method of claim 1 wherein said method is implemented by an integration engine based on a Spring Integration Framework.

9. A computer program product for sending a message from a source application to a target application, said message comprising a message payload and a header element comprising routing information, said computer program product comprising a non-transitory machine-readable storage medium having encoded therein executable code of one or more software programs, wherein the one or more software programs when executed perform the following steps:
processing said header element, using at least one processing device of an integration engine, to route said message to said target application;
transforming, using said at least one processing device of said integration engine, a message format of said message to a different message format to change a message format of said source application to a message format of said target application;
storing, using said at least one processing device of said integration engine, said message payload using a claim-Check Enterprise Application Integration (EAI) pattern;
applying, using said at least one processing device of said integration engine, one or more business rules to said message payload to dynamically change a next endpoint in said header element for said message; and
providing, using said at least one processing device of said integration engine, said transformed message to said target application.

10. The computer program product of claim 9 wherein said step of storing said message payload using said claim-Check EAI pattern reduces a data volume of said message.

11. The computer program product of claim 10 wherein said channel interceptor updates said next endpoint of said routing information in said flow based on said one or more business rules applied to said message payload.

12. The computer program product of claim 9 further comprising the step of updating said routing information of said header element using a channel interceptor.

13. An integration engine system for sending a message from a source application to a target application, said message comprising a message payload and a header element comprising routing information, comprising:
a memory; and
at least one processing device, coupled to the memory, operative to implement the following steps:
process said header element, using said at least one processing device of an integration engine, to route said message to said target application;
transform, using said at least one processing device of said integration engine, a message format of said message to a different message format to change a message format of said source application to a message format of said target application;
store, using said at least one processing device of said integration engine, said message payload using a claim-Check Enterprise Application Integration (EAI) pattern;
apply, using said at least one processing device of said integration engine, one or more business rules to said message payload to dynamically change a next endpoint in said header element for said message; and
provide, using said at least one processing device of said integration engine, said transformed message to said target application.

14. The integration engine system of claim 13 wherein said message payload is stored using said claim-Check EAI pattern that reduces a data volume of said message.

15. The integration engine system of claim 13 further comprising one or more transport adapters for transforming said message format of said message to a different message format for said target application.

16. The integration engine system of claim 15 wherein said message format of said message comprises one or more of Java Message Services (JMS), Hypertext Transfer Protocol (http), File Transfer Protocol (FTP), Transmission Control Protocol (TCP), Remote System Invocation (RMI), Internet Interoperable Protocol (IIOP) and User Datagram Protocol (UDP).

17. The integration engine system of claim 13 further comprising a channel interceptor to update said routing information of said header element.

18. The integration engine system of claim 17 wherein said channel interceptor updates said next endpoint of said routing information in said flow based on said one or more business rules applied to said message payload.

19. The integration engine system of claim 13 further comprising a header-based router to process said header element to route said message to a next endpoint in a flow.

20. The integration engine system of claim 13 wherein said integration engine system is based on a Spring Integration Framework.

Assignees

• Emc Corp

Inventors

• Shanmugam Karunanithi

Classifications

• H04L67/10 Primary

  in which an application is distributed across nodes in the network (software deployment G06F8/60; multiprogramming arrangements G06F9/46) · CPC title

• H04L67/63 Primary

  Routing a service request depending on the request content or context · CPC title

• G06Q10/103 Primary

  Workflow collaboration or project management · CPC title

• G06Q50/40

  Business processes related to the transportation industry (shipping G06Q10/083) · CPC title