Restartable Message Aggregation Flows in Containers

A computer system for controlling message aggregation flows, the computer system comprising:

• a communication fabric;
• a set of computer-readable storage media connected to the communication fabric, wherein the set of computer-readable storage media collectively stores program instructions;
• and
• a set of processors connected to the communication fabric, wherein the set of processors executes the program instructions to:
• retrieve, using a fan-in message flow of an integration engine in a replica container, a complete set of reply messages containing information from a particular set of queues in a message queue manager container in response to determining, using the fan-in message flow of the integration engine in the replica container, that all of a plurality of independently identifiable related fan-in messages corresponding to an input message requesting the information have been received as the complete set of reply messages from a plurality of back-end servers containing the information by the particular set of queues in the message queue manager container based on tracking of the plurality of independently identifiable related fan-in messages;
• aggregate, using the fan-in message flow of the integration engine in the replica container, the complete set of reply messages containing the information to generate a single response message containing the information;
• and
• send the single response message containing the information to a client device requesting the information via a network.

A computer program product for controlling message aggregation flows, the computer program product comprising a set of computer-readable storage media having program instructions collectively stored therein, the program instructions executable by a computer to cause the computer to:

• retrieve, using a fan-in message flow of an integration engine in a replica container, a complete set of reply messages containing information from a particular set of queues in a message queue manager container in response to determining, using the fan-in message flow of the integration engine in the replica container, that all of a plurality of independently identifiable related fan-in messages corresponding to an input message requesting the information have been received as the complete set of reply messages from a plurality of back-end servers containing the information by the particular set of queues in the message queue manager container based on tracking of the plurality of independently identifiable related fan-in messages;
• aggregate, using the fan-in message flow of the integration engine in the replica container, the complete set of reply messages containing the information to generate a single response message containing the information;
• and
• send the single response message containing the information to a client device requesting the information via a network.