Coupling state aware systems

A method of coupling asynchronous process interaction between computer systems integrated within an overall system of interconnected systems, the method comprising:

• receiving a set of information describing an invocation call for execution of a first process on a first system integrated within the overall system, a second process executing on a second system integrated within the overall system making the invocation call, the set of information specifying a first unique identifier for the first process generated by the first system and a callback endpoint in the second process implemented to receive notification upon completion of the first process by the first system;
• correlating a first callback argument received upon completion of the first process that includes the first unique identifier for the first process with the set of information according to the first unique identifier for the first process;
• sending a notification message to the callback endpoint in the second process specified in the set of information indicating completion of the first process;
• translating each callback argument received upon completion of each process invoked for execution on each system integrated within the overall system into a corresponding callback record according to a common protocol, further comprising adding each callback record to a callback queue, and wherein each callback record includes a unique identifier generated for the corresponding process sending the callback argument by the system on which the process is invoked for execution, wherein correlating the first callback argument with the set of information comprises receiving the first callback argument from the first system upon completion of the first process, translating the first callback argument into a first callback record according to the common protocol, and correlating the first callback record with the set of information according to the first unique identifier for the first process;
• analyzing the callback queue to attempt locate the first callback record according to the first unique identifier for the first process upon receiving the set of information;
• creating a first event correlation record for the first process that includes the set of information if the first callback record is not located in the callback queue upon receiving the set of information, and wherein correlating the first callback argument with the set of information comprises correlating the first callback record with the first event correlation record according to the first unique identifier for the first process if the first callback record is not located in the callback queue upon receiving the set of information;
• and
• storing the first event correlation record in a correlation record data store if the first callback record is not located in the callback queue upon receiving the set of information;
• wherein the first system is not implemented to provide the first callback argument upon completion of the first process, and wherein correlating the first callback argument with the first set of information comprises accessing a first interface mechanism implemented by the first system to periodically poll the first system to receive a current execution state of the first process on the first system according to the first unique identifier for the first process, constructing an emulation of the first callback record for the first process upon the current execution state of the first process being determined to be completed during periodic polling of the first system, and correlating the emulated first callback record with the first event correlation record according to the first unique identifier for the first process.

A method of coupling asynchronous process interaction between computer systems integrated within an overall system of interconnected systems, the method comprising:

• receiving a set of information describing an invocation call for execution of a first process on a first system integrated within the overall system, a second process executing on a second system integrated within the overall system making the invocation call, the set of information specifying a first unique identifier for the first process generated by the first system and a callback endpoint in the second process implemented to receive notification upon completion of the first process by the first system;
• correlating a first callback argument received upon completion of the first process that includes the first unique identifier for the first process with the set of information according to the first unique identifier for the first process;
• sending a notification message to the callback endpoint in the second process specified in the set of information indicating completion of the first process;
• translating each callback argument received upon completion of each process invoked for execution on each system integrated within the overall system into a corresponding callback record according to a common protocol, further comprising adding each callback record to a callback queue, and wherein each callback record includes a unique identifier generated for the corresponding process sending the callback argument by the system on which the process is invoked for execution, wherein correlating the first callback argument with the set of information comprises receiving the first callback argument from the first system upon completion of the first process, translating the first callback argument into a first callback record according to the common protocol, and correlating the first callback record with the set of information according to the first unique identifier for the first process;
• analyzing the callback queue to attempt locate the first callback record according to the first unique identifier for the first process upon receiving the set of information;
• creating a first event correlation record for the first process that includes the set of information if the first callback record is not located in the callback queue upon receiving the set of information, and wherein correlating the first callback argument with the set of information comprises correlating the first callback record with the first event correlation record according to the first unique identifier for the first process if the first callback record is not located in the callback queue upon receiving the set of information;
• and
• storing the first event correlation record in a correlation record data store if the first callback record is not located in the callback queue upon receiving the set of information;
• wherein the correlation record data store is maintained by a process correlation management module, the process correlation management module providing a second interface mechanism accessible to perform a specified set of addition, deletion, and modification operations on event correlation records maintained in the correlation record data store.

A non-transitory computer-usable medium having computer readable instructions stored thereon for execution by a processor to perform a method of coupling asynchronous process interaction between computer systems integrated within an overall system of interconnected systems, the method comprising:

• receiving a set of information describing an invocation call for execution of a first process on a first system integrated within the overall system, a second process executing on a second system integrated within the overall system making the invocation call, the set of information specifying a first unique identifier for the first process generated by the first system and a callback endpoint in the second process implemented to receive notification upon completion of the first process by the first system;
• correlating a first callback argument received upon completion of the first process that includes the first unique identifier for the first process with the set of information according to the first unique identifier for the first process;
• translating each callback argument received upon completion of each process invoked for execution on each system integrated within the overall system into a corresponding callback record according to a common protocol, further comprising adding each callback record to a callback queue, and wherein each callback record includes a unique identifier generated for the corresponding process sending the callback argument by the system on which the process is invoked for execution;
• and
• sending a notification message to the callback endpoint in the second process specified in the set of information indicating completion of the first process;
• wherein the set of information describing the invocation call includes a first timeout event for the first process, and wherein, if the first translated callback record is not located in the callback queue upon receiving the set of information, correlating the first callback argument with the set of information comprises periodically scanning the correlation record data store according to the first unique identifier for the first process to determine a status of the first timeout event in the first event correlation record, accessing a first interface mechanism implemented by the first system to periodically poll the first system to receive a current execution state of the first process on the first system according to the first unique identifier for the first process upon the status of the first timeout event being determined to be expired during periodic scanning of the correlation record data store, constructing an emulation of the first callback record for the first process upon the current execution state of the first process being determined to be completed during periodic polling of the first system, and correlating the emulated first callback record with the first event correlation record according to the first unique identifier for the first process.

A data processing system comprising:

• at least one processor;
• a random access memory for storing data and programs for execution by the at least one processor;
• and
• computer readable instructions stored in the random access memory for execution by the at least one processor to perform a method of coupling asynchronous process interaction between computer systems integrated within an overall system of interconnected systems, the method comprising:
• receiving a set of information describing an invocation call for execution of a first process on a first system integrated within the overall system, a second process executing on a second system integrated within the overall system making the invocation call, the set of information specifying a first unique identifier for the first process generated by the first system and a callback endpoint in the second process implemented to receive notification upon completion of the first process by the first system;
• correlating a first callback argument received upon completion of the first process that includes the first unique identifier for the first process with the set of information according to the first unique identifier for the first process;
• translating each callback argument received upon completion of each process invoked for execution on each system integrated within the overall system into a corresponding callback record according to a common protocol, further comprising adding each callback record to a callback queue, and wherein each callback record includes a unique identifier generated for the corresponding process sending the callback argument by the system on which the process is invoked for execution;
• and
• sending a notification message to the callback endpoint in the second process specified in the set of information indicating completion of the first process;
• wherein the set of information describing the invocation call includes a first timeout event for the first process, and wherein, if the first translated callback record is not located in the callback queue upon receiving the set of information, correlating the first callback argument with the set of information comprises periodically scanning the correlation record data store according to the first unique identifier for the first process to determine a status of the first timeout event in the first event correlation record, accessing a first interface mechanism implemented by the first system to periodically poll the first system to receive a current execution state of the first process on the first system according to the first unique identifier for the first process upon the status of the first timeout event being determined to be expired during periodic scanning of the correlation record data store, constructing an emulation of the first callback record for the first process upon the current execution state of the first process being determined to be completed during periodic polling of the first system, and correlating the emulated first callback record with the first event correlation record according to the first unique identifier for the first process.