Managing business process messaging

• US 8,745,635 B2
• Filed: 04/24/2012
• Issued: 06/03/2014
• Est. Priority Date: 04/24/2012
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP AG (SAP SE)
• Inventors: Balko, Soeren, Schubert, Harald
• Primary Examiner(s): Anya, Charles E
• Application Number:
  US13/454,366
• Publication Number:
  US 20130283291A1
• Time in Patent Office: 770 Days
• Field of Search: None
• US Class Current: 719/313
• CPC Class Codes: G06F 2209/547 Messaging middleware
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

Systems, methods, apparatus, and computer-readable media for managing business process messaging include receiving a business process message at a first node of multiple nodes in a distributed computing environment, the business process message comprising a message payload; correlating the business process message with a business process executing on one or more of the plurality of nodes in the distributed computing environment based on the message payload; identifying the one or more of the plurality of nodes in the distributed computing environment; providing the business process message to the identified one or more of the plurality of nodes; and mapping the message payload to the business process executing on the identified one or more of the plurality of nodes.

Claims

1. A method performed with a distributed computing system for managing business process messaging, the method comprising:

receiving a business process message at a first node of a plurality of nodes in a distributed computing environment, the business process message comprising a message payload;

correlating the business process message with a business process executing on one or more of the plurality of nodes in the distributed computing environment based on the message payload;

identifying the one or more of the plurality of nodes in the distributed computing environment, the identification comprising;

determining that the business process is executing on one or more nodes other than the first node in the plurality of nodes;

constructing a script comprising the message payload; and

publishing the script to a queue available to the plurality of nodes;

providing the business process message to the identified one or more of the plurality of nodes by running, on the one or more nodes other than the first node in the plurality of nodes, the script from the queue; and

subsequent to running the script, mapping the message payload to the business process executing on the identified one or more of the plurality of nodes other than the first node.

2. The method of claim 1, wherein providing the business process message and mapping the message payload occur asynchronously.

3. The method of claim 1, wherein identifying the one or more of the plurality of nodes in the distributed computing environment comprises:

identifying one node of the plurality of nodes in the distributed computing environment on which the business process is executing; and

determining that the identified one node and the first node are the same node.

4. The method of claim 3, wherein providing the business process message to the identified one or more of the plurality of nodes comprises:

directly associating the business process message to the business process executing on the identified one node.

5. The method of claim 1, further comprising:

constructing a second script comprising the message payload;

determining that the business process has terminated prior to mapping the message payload to the business process executing on the identified one or more of the plurality of nodes;

based on the determination, logging the second script for subsequent presentation to a user.

6. The method of claim 1, wherein providing the business process message to the identified one or more of the plurality of nodes comprises:

creating one or more proxy objects associated with the business process executing on one or more of the plurality of nodes;

creating a matching business process message for each of the one or more proxy objects; and

providing the matching business process message to the one or more of the plurality of nodes.

7. A non-transitory computer storage medium encoded with a computer program, the program comprising instructions that when executed by one or more computers cause the one or more computers to perform operations comprising:

receiving a business process message at a first node of a plurality of nodes in a distributed computing environment, the business process message comprising a message payload;

correlating the business process message with a business process executing on one or more of the plurality of nodes in the distributed computing environment based on the message payload;

identifying the one or more of the plurality of nodes in the distributed computing environment, the identification comprising;

determining that the business process is executing on one or more nodes other than the first node in the plurality of nodes;

constructing a script comprising the message payload; and

publishing the script to a queue available to the plurality of nodes;

providing the business process message to the identified one or more of the plurality of nodes by running, on the one or more nodes other than the first node in the plurality of nodes, the script from the queue; and

subsequent to running the script, mapping the message payload to the business process executing on the identified one or more of the plurality of nodes other than the first node.

8. The non-transitory computer storage medium of claim 7, wherein providing the business process message and mapping the message payload occur asynchronously.

9. The non-transitory computer storage medium of claim 7, wherein identifying the one or more of the plurality of nodes in the distributed computing environment comprises:

identifying one node of the plurality of nodes in the distributed computing environment on which the business process is executing; and

determining that the identified one node and the first node are the same node.

10. The non-transitory computer storage medium of claim 9, wherein providing the business process message to the identified one or more of the plurality of nodes comprises:

directly associating the business process message to the business process executing on the identified one node.

11. The non-transitory computer storage medium of claim 7, wherein the operations further comprise:

constructing a second script comprising the message payload;

determining that the business process has terminated prior to mapping the message payload to the business process executing on the identified one or more of the plurality of nodes;

based on the determination, logging the second script for subsequent presentation to a user.

12. The non-transitory computer storage medium of claim 7, wherein providing the business process message to the identified one or more of the plurality of nodes comprises:

creating one or more proxy objects associated with the business process executing on one or more of the plurality of nodes;

creating a matching business process message for each of the one or more proxy objects; and

providing the matching business process message to the one or more of the plurality of nodes.

13. A system of one or more computers configured to perform operations comprising:

receiving a business process message at a first node of a plurality of nodes in a distributed computing environment, the business process message comprising a message payload;

correlating the business process message with a business process executing on one or more of the plurality of nodes in the distributed computing environment based on the message payload;

identifying the one or more of the plurality of nodes in the distributed computing environment, the identification comprising;

determining that the business process is executing on one or more nodes other than the first node in the plurality of nodes;

constructing a script comprising the message payload; and

publishing the script to a queue available to the plurality of nodes;

providing the business process message to the identified one or more of the plurality of nodes by running, on the one or more nodes other than the first node in the plurality of nodes, the script from the queue; and

subsequent to running the script, mapping the message payload to the business process executing on the identified one or more of the plurality of nodes other than the first node.

14. The system of claim 13, wherein providing the business process message and mapping the message payload occur asynchronously.

15. The system of claim 13, wherein identifying the one or more of the plurality of nodes in the distributed computing environment comprises:

identifying one node of the plurality of nodes in the distributed computing environment on which the business process is executing; and

determining that the identified one node and the first node are the same node.

16. The system of claim 15, wherein providing the business process message to the identified one or more of the plurality of nodes comprises:

directly associating the business process message to the business process executing on the identified one node.

17. The system of claim 13, wherein the operations further comprise:

constructing a second script comprising the message payload;

determining that the business process has terminated prior to mapping the message payload to the business process executing on the identified one or more of the plurality of nodes;

based on the determination, logging the second script for subsequent presentation to a user.

18. The system of claim 13, wherein providing the business process message to the identified one or more of the plurality of nodes comprises:

creating one or more proxy objects associated with the business process executing on one or more of the plurality of nodes;

creating a matching business process message for each of the one or more proxy objects; and

providing the matching business process message to the one or more of the plurality of nodes.