Aggregation messaging within an integration environment

A computer implemented method for executing an aggregation method in an integration environment, the method comprising:

• issuing, in response to receiving an input message from a requesting application, a first control signal, using, in response to receiving the first control signal, a first logical thread to:
• generate an entry associated with an in-memory data structure, wherein the entry comprises an aggregation identifier associated with the input message and a response identifier associated with a response message associated with a target application, wherein no mutual-exclusion locks are applied by an aggregator;
• determine, by the aggregator, that the response message has been received by comparing the response identifier with a corresponding response identifier received from the target application;
• update, in response to receiving the response message from the target application, the entry in a second logical thread with the response message;
• and
• add the updated entry to the in-memory data structure, where no mutual-exclusion locks are applied are applied by the aggregator.

A computer program product comprising a computer-readable storage medium having program instructions embodied therewith, wherein the computer-readable storage medium is not a transitory signal per se, the program instructions executable by a processor to cause the processor to perform a method comprising:

• issuing, in response to receiving an input message from a requesting application, a first control signal, using, in response to receiving the first control signal, a first logical thread to:
• generate an entry associated with an in-memory data structure, wherein the entry comprises an aggregation identifier associated with the input message and a response identifier associated with a response message associated with a target application, wherein no mutual-exclusion locks are applied by an aggregator;
• update, in response to receiving the response message from the target application, the entry in a second logical thread with the response message;
• mark, by the aggregator and responsive to the response message being received prior to a timeout value expiring, an aggregation method associated with the entry as completing successfully;
• and
• add the updated entry to the in-memory data structure, wherein no mutual-exclusion locks are applied by the aggregator.