System and method to provide BPEL support for correlation aggregation

• US 9,020,883 B2
• Filed: 05/22/2012
• Issued: 04/28/2015
• Est. Priority Date: 02/22/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Mi, Glenn, Kumar, Yogesh
• Primary Examiner(s): Wathen, Brian W
• Application Number:
  US13/477,892
• Publication Number:
  US 20130219412A1
• Time in Patent Office: 1,071 Days
• Field of Search: 707/602
• US Class Current: 707/602
• CPC Class Codes: G06F 16/254 Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses
• CPC Class Codes: G06Q 10/06 Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling
• CPC Class Codes: H04L 67/563 Data redirection of data network streams
• CPC Class Codes: H04L 67/564 Enhancement of application control based on intercepted application data

Abstract

A system and method are disclosed for providing BPEL support for correlation aggregation. The system can comprise a business process engine, executing on one or more application servers organized in a cluster. The system can comprise a database including a table which stores records relating to message groups and business process instances. When a message is received by the business process engine, the business process engine can determine an identity associated with the message, and check the database to determine if there is an entry associated with the identity. If there is no entry associated with the identity, then the business process engine can instantiate a first business process instance associated with the identity, and if there is an entry associated with the identity, then the business process engine can route the message to a business process instance associated with the identity.

Claims

1. A system for providing BPEL support for correlation aggregation, comprising:

a business process engine, executing on one or more application servers organized in a cluster, wherein each application server executes on one or more microprocessors;

a database including a table which stores records relating to message groups and business process instances; and

wherein, when a message is received by the business process engine, the business process engine is configured to,

determine an identity associated with the message,

check the database to determine if there is an entry associated with the identity,

if there is no entry associated with the identity, then mark the message as a business process instantiating message, and instantiate a first business process instance associated with the identity, and

if there is an entry associated with the identity, then route the message to a business process instance associated with the identity.

2. The system of claim 1, further comprising:

a business process aggregator, at the business process engine, which is operable to route the messages received by the business process engine.

3. The system of claim 1, wherein the identity is a correlation ID.

4. The system of claim 1, wherein the message is of a type which can instantiate a new business process instance or be routed to an existing business process instance mid-process.

5. The system of claim 1, wherein when subsequent messages are received by the business process engine which share the identity with the message, the business process engine routes the subsequent messages to the first business process instance.

6. The system of claim 1, wherein the business process engine is configured such that, if there is an entry associated with the identity, the business process engine marks the message as associated with an existing business process instance and routes the message to the business process instance associated with the identity.

7. The system of claim 1, wherein the business process engine is a BPEL engine.

8. A method for providing BPEL support for correlation aggregation, comprising:

providing a business process engine, executing on one or more application servers organized in a cluster, wherein each application server executes on one or more microprocessors;

providing a database including a table which stores records relating to message groups and business process instances; and

receiving a message by the business process engine;

determining an identity associated with the message;

checking the database to determine if there is an entry associated with the identity;

if there is no entry associated with the identity, then marking the message as a business process instantiating message, and instantiating a first business process instance associated with the identity; and

if there is an entry associated with the identity, then routing the message to a business process instance associated with the identity.

9. The method of claim 8, further comprising:

routing the messages received by the business process engine by a business process aggregator at the business process engine.

10. The method of claim 8, wherein the identity is a correlation ID.

11. The method of claim 8, wherein the message is of a type which can instantiate a new business process instance or be routed to an existing business process instance mid-process.

12. The method of claim 8, further comprising:

when subsequent messages are received by the business process engine which share the identity with the message, routing the subsequent messages to the first business process instance.

13. The method of claim 8, further comprising:

marking the message as associated with an existing business process instance if there is an entry associated with the identity.

14. The method of claim 8, wherein the business process engine is a BPEL engine.

15. A non-transitory computer readable storage medium including instructions stored thereon which, when executed by a computer, cause the computer to perform steps comprising:

providing a business process engine, executing on one or more application servers organized in a cluster, wherein each application server executes on one or more microprocessors;

providing a database including a table which stores records relating to message groups and business process instances; and

receiving a message by the business process engine;

determining an identity associated with the message;

checking the database to determine if there is an entry associated with the identity;

if there is no entry associated with the identity, then marking the message as a business process instantiating message, and instantiating a first business process instance associated with the identity; and

if there is an entry associated with the identity, then routing the message to a business process instance associated with the identity.

16. The non-transitory computer readable storage medium of claim 15, further comprising:

routing the messages received by the business process engine by a business process aggregator at the business process engine.

17. The non-transitory computer readable storage medium of claim 15, wherein the identity is a correlation ID.

18. The non-transitory computer readable storage medium of claim 15, wherein the message is of a type which can instantiate a new business process instance or be routed to an existing business process instance mid-process.

19. The non-transitory computer readable storage medium of claim 15, further comprising:

when subsequent messages are received by the business process engine which share the identity with the message, routing the subsequent messages to the first business process instance.

20. The non-transitory computer readable storage medium of claim 15, further comprising:

marking the message as associated with an existing business process instance if there is an entry associated with the identity.