Event-based orchestration in distributed order orchestration system

Patent metadata

Field	Value
Publication number	US-9658901-B2
Application number	US-94508410-A
Country	US
Kind code	B2
Filing date	Nov 12, 2010
Priority date	Nov 12, 2010
Publication date	May 23, 2017
Grant date	May 23, 2017

Abstract

A distributed order orchestration system is provided that includes an event manager configured to generate and publish a set of events based on a process state and metadata stored in a database. A set of subscribers can consume the set of events, and each subscriber can execute a task based on the consumed event.

First claim

We claim:

1. A non-transitory computer-readable medium having instructions stored thereon, when executed by a processor, cause the processor to orchestrate an order using an event-based orchestration framework including a capture layer, a decomposition layer, an orchestration layer, a task layer and an external interface layer, the orchestration comprising:
at the capture layer:
receiving, at an order capture module, a web order from a customer computer over a network;
creating a source order object from the web order;

at the decomposition layer:
receiving the source order object from the order capture module;
creating a distributed order orchestration (DOO) order object from the source order object, the DOO order object including a plurality of attribute values;
defining a process state and metadata for an orchestration process and storing the process state and metadata in a data table of a database, the process state comprising the DOO order attribute values and a state of the orchestration process that indicates which steps of the orchestration process have been executed, and the metadata comprising one or more steps of the orchestration process and an order of the one or more steps of the orchestration process;

at the orchestration layer:
determining, by an event manager, a step of the orchestration process to execute based on the steps of the orchestration process that have been executed as indicated by the process state and the order of the one or more steps of the orchestration process indicated by the metadata stored in the database;
generating an event based on the determined step of the orchestration process to execute and the metadata, the event comprising instructions to execute a task that corresponds to the determined step of the orchestration process to execute, and an event type, the task including a plurality of subtasks;
publishing the event across an event messaging system;

at the task layer:
retrieving, by a task layer service decoupled from the event manager, the published event from the messaging system;
determining whether the task layer service subscribes to the event type of the published event;
when the task layer service subscribes to the event type:
executing each of the subtasks,
generating at least one task message to an external system,
processing at least one task result message from the external system, and
updating the process state stored in the database, after executing each subtask and after processing the task result message, including updating at least one DOO order attribute value;

at the external interface layer:
sending the task message to the external system over the network; and
receiving the task result message from the external system over the network.

2. The non-transitory computer-readable medium of claim 1 , wherein the event manager and the task layer service are each distinct components of a distributed order orchestration system.

3. The non-transitory computer-readable medium of claim 2 , wherein the event manager comprises a stateless process invoked by an orchestration system.

4. The non-transitory computer-readable medium of claim 1 , wherein the DOO order object includes a header object, one or more line objects, and one or more fulfillment line objects, the header object containing a hierarchy of the order, the line object containing information of the corresponding line of the order, and the fulfillment line object corresponding to a supply action of a corresponding fulfillment system which processes the order line.

5. The non-transitory computer-readable medium of claim 1 , wherein the metadata is used to define tasks within the order and to invoke services related to the tasks.

6. The non-transitory computer-readable medium of claim 5 , wherein the services comprise task layer services.

7. The non-transitory computer-readable medium of claim 1 , wherein said determining a step of the orchestration process to execute, generating an event and publishing the event are repeated until the process state reaches an exit status.

8. The non-transitory computer-readable medium of claim 1 ,
wherein a mediator retrieves the event,
wherein the mediator invokes the task layer service based on parameters contained within the event,
wherein the task layer service executes the task based on the published event, and
wherein the task layer service updates the process state stored in the database after executing the task.

9. The non-transitory computer-readable medium of claim 1 , wherein the event messaging system comprises one or more message channels, where each message channel is configured to transmit an event from the event manager to the task layer service.

10. The non-transitory computer-readable medium of claim 9 , wherein each message channel comprises a publish-subscribe message channel comprising one input channel and one or more output channels, wherein each output channel corresponds to a unique task layer service.

11. The non-transitory computer-readable medium of claim 1 , wherein the determining the event to generate further comprises,
determining whether any steps of the orchestration process remain,
selecting a process step,
determining whether the selected process step depends on other process steps, and
determining whether the other process steps have completed, when it is determined that the selected process step depends on other process steps.

12. The non-transitory computer-readable medium of claim 1 , wherein the orchestrating further comprises at least one of, publishing events for parallel steps of the orchestration process, splitting the orchestration process, and processing a change request to the order.

13. The non-transitory computer-readable medium of claim 1 , wherein the orchestrating further comprises publishing events for conditional steps of the orchestration process.

14. The non-transitory computer-readable medium of claim 1 , wherein the processor is further configured to:
determine that a change request has been initiated based on the process state and the metadata stored in the database;
generate a set of one or more events that correspond to one or more steps of the orchestration process, wherein each event comprises instructions to execute a task that compensates a step of the orchestration process; and
publish the set of events across the event messaging system, wherein each event is published one at a time;
wherein one or more task layer services retrieve the published set of events, and execute one or more tasks that compensate the one or more steps of the orchestration process.

15. A computer-implemented method for orchestrating an order using an event-based orchestration framework including a capture layer, a decomposition layer, an orchestration layer, a task layer and an external interface layer, the computer-implemented method comprising:
at the capture layer:
receiving, at an order capture module, a web order from a customer computer over a network;
creating a source order object from the web order;

at the decomposition layer:
receiving the source order object from the order capture module;
creating a distributed order orchestration (DOO) order object from the source order object, the DOO order object including a plurality of attribute values;
defining a process state and metadata for an orchestration process and storing the process state and metadata in a data table of a database, the process state comprising the DOO order object attribute values and a state of the orchestration process that indicates which steps of the orchestration process have been executed, and t

Assignees

• Addala Raju
• Singh Alok
• Rijhsinghani Sumeet
• Butt Zeeshan
• Oracle Int Corp

Inventors

• Addala Raju
• Singh Alok
• Rijhsinghani Sumeet
• Butt Zeeshan

Classifications

• G06F2209/544

  Remote · CPC title

• G06F9/542 Primary

  Event management; Broadcasting; Multicasting; Notifications · CPC title

• G06Q10/087

  Inventory or stock management, e.g. order filling, procurement or balancing against orders · CPC title