Generic wait service: pausing and resuming a plurality of BPEL processes arranged in correlation sets by a central generic wait server

• US 10,296,373 B2
• Filed: 05/27/2014
• Issued: 05/21/2019
• Est. Priority Date: 09/17/2008
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Addala, Raju, Singh, Alok, Kozic, Scott, Sridharan, Sarita, Datti, Sunita
• Primary Examiner(s): Ghaffari, Abu
• Assistant Examiner(s): Ayers, Michael W
• Application Number:
  US14/288,265
• Publication Number:
  US 20140282602A1
• Time in Patent Office: 1,820 Days
• CPC Class Codes: G06F 2209/544 Remote
• CPC Class Codes: G06F 9/485 Task life-cycle, e.g. stopping, restarting, resuming execution G06F9/4881 takes precedence
• CPC Class Codes: G06F 9/52 Program synchronisation; Mutual exclusion, e.g. by means of semaphores
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

A method of pausing a plurality of service-oriented application (SOA) instances may include receiving, from an instance of an SOA entering a pause state, an initiation message. The initiation message may include an exit criterion that identifies a business condition that must be satisfied before the instance of the SOA exits the pause state. The method may also include receiving a notification from an event producer, the notification comprising a status of a business event and determining whether the status of the business event satisfies the business condition of the exit criterion. The method may additionally include sending, in response to a determination that the status of the business event satisfies the business condition of the exit criterion, an indication to the instance of the SOA that the business condition has been satisfied such that the instance of the SOA can exit the pause state.

Claims

1. A method of pausing processing of a plurality of business processes by a plurality of service-oriented application (SOA) instances running on one or more application servers, wherein each of the plurality of business processes is processed by at least one associated SOA instance of the plurality of SOA instances, each of the plurality of business processes is processed by at least one associated event producer of a plurality of event producers running on one or more event servers, and each of the plurality of business processes is associated with a processing status corresponding to the processing performed on the business process, the method comprising:

receiving, by a generic wait server, a plurality of initiation messages from the plurality of SOA instances when each of the plurality of SOA instances are entering pause states, wherein each of the plurality of initiation messages comprises;

a reference to the business processes of the plurality of business processes being processed by the associated SOA instance entering the pause state that sent the initiation message, wherein the business process is distinct from the associated SOA instance; and

an exit criterion that identifies a condition that must be satisfied by a status of the business processes before the associated SOA instance exits its pause state;

generating, by the generic wait server, one or more correlation sets, wherein;

each of the one or more correlation sets are associated with a particular business process of the plurality of business processes; and

each of the one or more correlation sets groups together a plurality of SOA instances to each associated business process;

receiving, by the generic wait server, a plurality of notifications from the plurality of event producers, wherein each of the plurality of notifications comprises;

a reference to the business process of the plurality of business processes being processed by the associated event producer, wherein the business process being processed by the associated event producer is distinct from the associated event producer; and

a status of the business process being processed by the associated event producer; and

for each notification in the plurality of notifications;

identifying, by the generic wait server, a correlation set whose particular business process corresponds to the business process referenced in the notification;

determining, by the generic wait server, whether the status of the business process in the notification satisfies the condition of the exit criterion of each of the plurality of associated SOA instances of the identified correlation set; and

causing, by the generic wait server, the plurality of SOA instances for which the associated conditions have been satisfied to exit their pause states and resume processing of their associated business processes.

2. The method of claim 1, wherein the generic wait server comprises a service module that is separate from the plurality of SOA instances and separate from the plurality of event producers, such that the plurality of SOA instances are decoupled from the plurality of event producers, and logic for determining whether the status satisfies the condition is encapsulated within the service module.

3. The method of claim 1, wherein the plurality of SOA instances can pause and/or execute parallel task flows.

4. The method of claim 1, wherein causing the plurality of SOA instances for which the associated conditions have been satisfied to exit their pause states comprises:

sending the status of the business process to the plurality of SOA instances for which the associated conditions have been satisfied.

5. The method of claim 1, further comprising, sending, in response to a determination that the status does not satisfy the condition of the exit criterion, indications that the condition has not been satisfied such that the plurality of associated SOA instances should stay in their pause states.

6. The method of claim 1, wherein determining, by the generic wait server, for each notification in the plurality of notifications, whether the status of the business process in the notification satisfies the condition of the exit criterion of each of the plurality of associated SOA instances comprises:

determining that a status of a product order has changed from unfulfilled to fulfilled.

7. The method of claim 1, wherein:

an SOA instance of the plurality of SOA instances comprises a Business Process Execution Language (BPEL) process;

an event producer of the plurality of event producers comprises a web service; and

the generic wait server comprises an asynchronous BPEL process.

8. The method of claim 1, wherein the one or more event servers are external to an enterprise and the generic wait server and the one or more application servers are internal to the enterprise, and wherein the plurality of notifications from the plurality of event producers are received through an intermediate update service that protects the generic wait server from direct exposure to external networks.

9. The method of claim 1, wherein the generic wait server, the one or more application servers, and the one or more event servers are each physically separate servers, wherein each of the physically separate servers runs its own operating system, and wherein each of the physically separate servers communicate with each other over a network.

10. The method of claim 1, wherein the plurality of notifications from the plurality of event producers are received through a one-way notification operation.

11. A non-transitory computer-readable medium comprising instructions which, when executed by one or more processors, cause the one or more processors to pause processing of a plurality of business processes by a plurality of service-oriented application (SOA) instances running on one or more application servers, wherein each of the plurality of business processes is processed by at least one associated SOA instance of the plurality of SOA instances, each of the plurality of business processes is processed by at least one associated event producer of a plurality of event producers running on one or more event servers, and each of the plurality of business processes is associated with a processing status corresponding to the processing performed on the business process, by performing operations comprising:

receiving, by a generic wait server, a plurality of initiation messages from the plurality of SOA instances when each of the plurality of SOA instances are entering pause states, wherein each of the plurality of initiation messages comprises;

a reference to the business processes of the plurality of business processes being processed by the associated SOA instance entering the pause state that sent the initiation message, wherein the business process is distinct from the associated SOA instance; and

an exit criterion that identifies a condition that must be satisfied by a status of the business processes before the associated SOA instance exits its pause state;

generating, by the generic wait server, one or more correlation sets, wherein;

each of the one or more correlation sets are associated with a particular business process of the plurality of business processes; and

each of the one or more correlation sets groups together a plurality of SOA instances to each associated business process;

receiving, by the generic wait server, a plurality of notifications from the plurality of event producers, wherein each of the plurality of notifications comprises;

a reference to the business process of the plurality of business processes being processed by the associated event producer, wherein the business process being processed by the associated event producer is distinct from the associated event producer; and

a status of the business process being processed by the associated event producer; and

for each notification in the plurality of notifications;

identifying, by the generic wait server, a correlation set whose particular business process corresponds to the business process referenced in the notification;

determining, by the generic wait server, whether the status of the business process in the notification satisfies the condition of the exit criterion of each of the plurality of associated SOA instances of the identified correlation set; and

causing, by the generic wait server, the plurality of SOA instances for which the associated conditions have been satisfied to exit their pause states and resume processing of their associated business processes.

12. The non-transitory computer-readable medium of claim 11, wherein the generic wait server comprises a service module that is separate from the plurality of SOA instances and separate from the plurality of event producers, such that the plurality of SOA instances are decoupled from the plurality of event producers, and logic for determining whether the status satisfies the condition is encapsulated within the service module.

13. The non-transitory computer-readable medium of claim 11, wherein the plurality of SOA instances can pause and/or execute parallel task flows.

14. The non-transitory computer-readable medium of claim 11, wherein causing the plurality of SOA instances for which the associated conditions have been satisfied to exit their pause states comprises:

sending the status of the business process to the plurality of SOA instances for which the associated conditions have been satisfied.

15. The non-transitory computer-readable medium of claim 11, further comprising additional instructions that cause the one or more processors to perform additional operations comprising sending, in response to a determination that the status does not satisfy the condition of the exit criterion, indications that the condition has not been satisfied such that the plurality of associated SOA instances should stay in their pause states.

16. The non-transitory computer-readable medium of claim 11, wherein determining, by the generic wait server, for each notification in the plurality of notifications, whether the status of the business process in the notification satisfies the condition of the exit criterion of each of the plurality of associated SOA instances comprises:

determining that a status of a product order has changed from unfulfilled to fulfilled.

17. The non-transitory computer-readable medium of claim 11, wherein:

an SOA instance of the plurality of SOA instances comprises a Business Process Execution Language (BPEL) process;

an event producer of the plurality of event producers comprises a web service; and

the operations performed by the one or more processors comprise an asynchronous BPEL process.

18. A system comprising:

one or more processors; and

one or more memory devices comprising instructions which, when executed by one or more processors, cause the one or more processors to pause processing of a plurality of business processes by a plurality of service-oriented application (SOA) instances running on one or more application servers, wherein each of the plurality of business processes is processed by at least one associated SOA instance of the plurality of SOA instances, each of the plurality of business processes is processed by at least one associated event producer of a plurality of event producers running on one or more event servers, and each of the plurality of business processes is associated with a processing status corresponding to the processing performed on the business process, by performing operations comprising;

receiving, by a generic wait server, a plurality of initiation messages from the plurality of SOA instances when each of the plurality of SOA instances are entering pause states, wherein each of the plurality of initiation messages comprises;

a reference to the business processes of the plurality of business processes being processed by the associated SOA instance entering the pause state that sent the initiation message, wherein the business process is distinct from the associated SOA instance; and

an exit criterion that identifies a condition that must be satisfied by a status of the business processes before the associated SOA instance exits its pause state;

generating, by the generic wait server, one or more correlation sets, wherein;

each of the one or more correlation sets are associated with a particular business process of the plurality of business processes; and

each of the one or more correlation sets groups together a plurality of SOA instances to each associated business process;

receiving, by the generic wait server, a plurality of notifications from the plurality of event producers, wherein each of the plurality of notifications comprises;

a reference to the business process of the plurality of business processes being processed by the associated event producer, wherein the business process being processed by the associated event producer is distinct from the associated event producer; and

a status of the business process being processed by the associated event producer; and

for each notification in the plurality of notifications;

identifying, by the generic wait server, a correlation set whose particular business process corresponds to the business process referenced in the notification;

determining, by the generic wait server, whether the status of the business process in the notification satisfies the condition of the exit criterion of each of the plurality of associated SOA instances of the identified correlation set; and

causing, by the generic wait server, the plurality of SOA instances for which the associated conditions have been satisfied to exit their pause states and resume processing of their associated business processes.

19. The system of claim 18, wherein the generic wait server comprises a service module that is separate from the plurality of SOA instances and separate from the plurality of event producers, such that the plurality of SOA instances are decoupled from the plurality of event producers, and logic for determining whether the status satisfies the condition is encapsulated within the service module.

20. The system of claim 18, wherein the plurality of SOA instances can pause and/or execute parallel task flows.