Timeout processing for aggregation messaging in an integration environment
View Patent ↗A method includes: receiving an initial request message in a request queue of the messaging system; receiving an aggregation reply message in a reply queue of the messaging system, wherein the aggregation reply message is received from an integration system that processes the initial request message, and wherein the aggregation reply message includes an aggregation identifier associated with the initial request message; in response to receiving the aggregation reply message, starting a timeout process; monitoring the timeout process; holding one or more messages that are in the reply queue and that include the aggregation identifier until the timeout process expires or an expected number of responses has been received; and making available the one or more messages that are in the reply queue and that include the aggregation identifier based on the timeout process expiring or the expected number of responses having been received.
1. A computer-implemented method comprising:
receiving, by a messaging system, an initial request message in a request queue of the messaging system, the initial request message being received from a requesting application;
receiving, by the messaging system, an aggregation reply message in a reply queue of the messaging system, wherein the aggregation reply message is received from an integration system that processes the initial request message for the requesting application, and wherein the aggregation reply message includes an aggregation identifier associated with the initial request message;
in response to receiving the aggregation reply message, starting, by the messaging system, a timeout process;
monitoring, by the messaging system, the timeout process;
holding, by the messaging system, one or more messages that are in the reply queue and that include the aggregation identifier until the timeout process expires or an expected number of responses has been received; and
making available, by the messaging system, the one or more messages that are in the reply queue and that include the aggregation identifier based on the timeout process expiring or the expected number of responses having been received.
2. The computer-implemented method of claim 1 , wherein the initial request message comprises an aggregation request message for aggregating responses from plural end applications.
3. The computer-implemented method of claim 2 , wherein the one or more messages that are in the reply queue and that include the aggregation identifier comprise one or more response messages received by the integration system from one or more of the plural end applications and written by the integration system directly to the reply queue.
4. The computer-implemented method of claim 1 , wherein the requesting application is prevented from reading the one or more messages that are in the reply queue and that include the aggregation identifier during the holding.
5. The computer-implemented method of claim 1 , wherein the requesting application is permitted to read the one or more messages that are in the reply queue and that include the aggregation identifier in response to the making available.
6. The computer-implemented method of claim 1 , wherein:
the one or more messages that are in the reply queue and that include the aggregation identifier comprise the aggregation reply message; and
based on the timeout process expiring and the reply queue including zero response messages that include the aggregation identifier, the making available comprises releasing the aggregation reply message to the requesting application.
7. The computer-implemented method of claim 6 , wherein the aggregation reply message comprises a zero-response timeout message.
8. The computer-implemented method of claim 1 , wherein:
the one or more messages that are in the reply queue and that include the aggregation identifier comprise one or more response messages that are in the reply queue and that include the aggregation identifier; and
based on the timeout process expiring and the one or more response messages being less than the expected number of responses, the making available comprises releasing the one or more response messages to the requesting application.
9. The computer-implemented method of claim 8 , wherein the one or more response messages are released to the requesting application as a single data set.
10. The computer-implemented method of claim 1 , wherein:
the one or more messages that are in the reply queue and that include the aggregation identifier comprise plural response messages that are in the reply queue and that include the aggregation identifier; and
based on the plural response messages being equal to the expected number of responses prior to the timeout process expiring, the making available comprises releasing the plural response messages to the requesting application prior to the timeout process expiring.
11. The computer-implemented method of claim 10 , wherein the plural response messages are released to the requesting application as a single data set.
12. The computer-implemented method of claim 1 , wherein the messaging system comprises message-oriented middleware between the requesting application and the integration system.
13. A computer program product comprising one or more computer readable storage media having program instructions collectively stored on the one or more computer readable storage media, the program instructions executable to:
receive, by a messaging system, an initial request message in a request queue of the messaging system, the initial request message being received from a requesting application, and the messaging system comprising message-oriented middleware between the requesting application and an integration system;
receive, by the messaging system, an aggregation reply message in a reply queue of the messaging system, wherein the aggregation reply message is received from the integration system that processes the initial request message for the requesting application, and wherein the aggregation reply message includes an aggregation identifier associated with the initial request message;
in response to receiving the aggregation reply message, start, by the messaging system, a timeout process;
monitor, by the messaging system, the timeout process;
hold, by the messaging system, one or more messages that are in the reply queue and that include the aggregation identifier until the timeout process expires or an expected number of responses has been received; and
make available, by the messaging system, the one or more messages that are in the reply queue and that include the aggregation identifier based on the timeout process expiring or the expected number of responses having been received.
14. The computer program product of claim 13 , wherein:
the initial request message comprises an aggregation request message for aggregating responses from plural end applications; and
the one or more messages that are in the reply queue and that include the aggregation identifier comprise one or more response messages received by the integration system from one or more of the plural end applications and written by the integration system directly to the reply queue.
15. The computer program product of claim 13 , wherein the requesting application is prevented from reading the one or more messages that are in the reply queue and that include the aggregation identifier during the holding.
16. The computer program product of claim 13 , wherein the requesting application is permitted to read the one or more messages that are in the reply queue and that include the aggregation identifier in response to the making available.
17. A system comprising:
a processor set, one or more computer readable storage media, and program instructions collectively stored on the one or more computer readable storage media, the program instructions executable to:
receive, by a messaging system, an initial request message in a request queue of the messaging system, the initial request message being received from a requesting application, and the messaging system comprising message-oriented middleware between the requesting application and an integration system;
receive, by the messaging system, an aggregation reply message in a reply queue of the messaging system, wherein the aggregation reply message is received from the integration system that processes the initial request message for the requesting application, and wherein the aggregation reply message includes an aggregation identifier associated with the initial request message;
in response to receiving the aggregation reply message, start, by the messaging system, a timeout process;
monitor, by the messaging system, the timeout process;
hold, by the messaging system, one or more messages that are in the reply queue and that include the aggregation identifier until the timeout process expires or an expected number of responses has been received; and
make available, by the messaging system, the one or more messages that are in the reply queue and that include the aggregation identifier based on the timeout process expiring or the expected number of responses having been received.
18. The system of claim 17 , wherein:
the initial request message comprises an aggregation request message for aggregating responses from plural end applications; and
the one or more messages that are in the reply queue and that include the aggregation identifier comprise one or more response messages received by the integration system from one or more of the plural end applications and written by the integration system directly to the reply queue.
19. The system of claim 17 , wherein the requesting application is prevented from reading the one or more messages that are in the reply queue and that include the aggregation identifier during the holding.
20. The system of claim 17 , wherein the requesting application is permitted to read the one or more messages that are in the reply queue and that include the aggregation identifier in response to the making available.