High-load business process scalability
First Claim
Patent Images
1. A computer-implemented method, comprising:
- initiating a polling request from a computer node to a messaging queue, wherein the computer node uses a polling time to poll the messaging queue for a message associated with a process instance associated with the computer node, and wherein the polling time associated with the process instance is dynamically modified for the process instance based on a calculation related to an average or median time in which new messages are received in the messaging queue;
identifying a message in the messaging queue for retrieval based on the polling request, wherein the message is associated with the process instance and previously added to the messaging queue for the process instance, wherein the determination of the association between the process instance and the message includes use of a correlation procedure that matches a payload and a context associated with the message received at the messaging queue to the process instance, and wherein the message is configured to persist in the messaging queue for the lifetime of the process instance;
removing the message from the messaging queue with an asynchronously de-coupled transaction using the process instance to identify the message; and
processing, by operation of a computer, the message using the process instance associated with the message.
2 Assignments
0 Petitions
Accused Products
Abstract
The present disclosure involves systems, software, and computer implemented methods for providing high-load business process scalability in cloud-based infrastructures. One process includes operations for receiving a message at a first computer node executing a first business process instance. A second business process instance associated with the message is identified. The message is sent to a messaging queue for retrieval by the second business process instance if the second business process instance is not located at the first computer node.
25 Citations
20 Claims
-
1. A computer-implemented method, comprising:
-
initiating a polling request from a computer node to a messaging queue, wherein the computer node uses a polling time to poll the messaging queue for a message associated with a process instance associated with the computer node, and wherein the polling time associated with the process instance is dynamically modified for the process instance based on a calculation related to an average or median time in which new messages are received in the messaging queue; identifying a message in the messaging queue for retrieval based on the polling request, wherein the message is associated with the process instance and previously added to the messaging queue for the process instance, wherein the determination of the association between the process instance and the message includes use of a correlation procedure that matches a payload and a context associated with the message received at the messaging queue to the process instance, and wherein the message is configured to persist in the messaging queue for the lifetime of the process instance; removing the message from the messaging queue with an asynchronously de-coupled transaction using the process instance to identify the message; and processing, by operation of a computer, the message using the process instance associated with the message. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A computer-accessible, non-transitory, storage medium encoded with computer-readable instructions configured to cause one or more data processing apparatus to:
-
initiate a polling request from a computer node to a messaging queue, wherein the computer node uses a polling time to poll the messaging queue for a message associated with a process instance associated with the computer node, and wherein the polling time associated with the process instance is dynamically modified for the process instance based on a calculation related to an average or median time in which new messages are received in the messaging queue; identify a message in the messaging queue for retrieval based on the polling request, wherein the message is associated with the process instance and previously added to the messaging queue for the process instance, wherein the determination of the association between the process instance and the message includes use of a correlation procedure that matches a payload and a context associated with the message received at the messaging queue to the process instance, and wherein the message is configured to persist in the messaging queue for the lifetime of the process instance; remove the message from the messaging queue with an asynchronously de-coupled transaction using the process instance to identify the message; and process the message using the process instance associated with the message. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. A computer-implemented system, comprising:
-
memory operable to store a messaging queue; and at least one hardware processor interoperably coupled to the memory and operable to; initiate a polling request from a computer node to the messaging queue, wherein the computer node uses a polling time to poll the messaging queue for a message associated with a process instance associated with the computer node, and wherein the polling time associated with the process instance is dynamically modified for the process instance based on a calculation related to an average or median time in which new messages are received in the messaging queue; identify a message in the messaging queue for retrieval based on the polling request, wherein the message is associated with the process instance and previously added to the messaging queue for the process instance, wherein the determination of the association between the process instance and the message includes use of a correlation procedure that matches a payload and a context associated with the message received at the messaging queue to the process instance, and wherein the message is configured to persist in the messaging queue for the lifetime of the process instance; remove the message from the messaging queue with an asynchronously de-coupled transaction using the process instance to identify the message; and process the message using the process instance associated with the message. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification