Providing dynamic latency in an integration flow

• US 10,277,489 B2
• Filed: 09/20/2018
• Issued: 04/30/2019
• Est. Priority Date: 11/20/2015
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Hosie, John, Ross, Martin A., Stirling, Craig H., Storey, Dominic J.
• Primary Examiner(s): Lazaro, David R
• Assistant Examiner(s): Henry, Mariegeorges A
• Application Number:
  US16/136,350
• Publication Number:
  US 20190020560A1
• Time in Patent Office: 222 Days
• Field of Search: 709223, 709224
• CPC Class Codes: G06F 9/5033 considering data affinity
• CPC Class Codes: H04L 41/5009 Determining service level performance parameters or violations of service level contracts, e.g. violations of agreed response time or mean time between failures [MTBF]
• CPC Class Codes: H04L 43/0852 Delays

Abstract

Providing dynamic latency in an integration flow. An integration flow connecting multiple integration nodes and including at least one repeat node is managed, wherein a repeat node repeats by sending a message, a variation of a message, or an element of a message to multiple paths or to a single path multiple times. A repeat node is registered with a workload manager component for monitoring. Data relating to the effect on performance by the integration flow including the monitored repeat node is collected. Required latencies or variations of latencies between firing of repeats of the repeat node based on the collected data are determined. The latencies or variations of latencies between firing of the repeats of the repeat node are instructed to influence dynamically a flow of elements through the repeat node.

Claims

1. A computer-implemented method comprising:

managing an integration flow connecting multiple integration nodes and including a first repeat node, wherein the first repeat node repeats by sending an element of a message to a path multiple times;

determining a latency between firing of repeats of the first repeat node based on data collected form the first repeat node, wherein the latency comprises a first time;

determining a priority of a first repeat of the first repeat node based on a priority of an incoming message;

weighting the latency for the repeats for the incoming message based on the priority, wherein weighting the latency based on the priority further comprises;

multiplying a first ratio by a delay time to generate a weighted latency having a second time, wherein the first ratio is based on a numerator comprising the priority of the incoming message and a denominator comprising a lowest priority for incoming messages; and

instructing the weighted latency between firing of the repeats of the first repeat node to influence a flow of elements through the first repeat node, and wherein instructing the weighted latency causes the repeat node to delay, by the second time, respective sendings of the element of the incoming message to the path.

2. The method of claim 1, further comprising registering the first repeat node for monitoring with a workload manager component.

3. The method of claim 1, wherein the determining the latency is based on an impact of repeats of the first repeat node on applications as determined by data collected from the first repeat node.

4. The method of claim 1, wherein the determining the latency is based on an impact of repeats of the repeat node on components downstream of the integration flow as determined by data collected from the first repeat node.

5. The method of claim 1, wherein data collected from the first repeat node comprises data from resources in the integration flow, and resources in systems effected by the first repeat node.

6. The method of claim 1, wherein data collected from the first repeat node comprises data from applications in the integration flow and application metrics.

7. The method of claim 1, wherein the instructing the weighted latency comprises providing additional code to the first repeat node.

8. The method of claim 1, wherein determining the latency further comprises:

determining that an application is reaching a predefined threshold of performance; and

instructing latencies in repeats of the first repeat node for the application.

9. The method of claim 8, wherein the method further comprises learning correlations between instructed latencies in the first repeat node and an effect on performance of applications.

10. The method of claim 8, wherein the application is a real time traffic serving application, and wherein the predefined threshold is set in a service level agreement.

11. The method of claim 1, wherein the integration flow is an aggregation pattern and the first repeat node is an aggregation node with repeats selected from the group consisting of:

branching repeats, and iterating repeats.

12. A computer system comprising:

a memory; and

a processor in communication with the memory, wherein the computer system is configured to perform a method, the method comprising;

managing an integration flow connecting multiple integration nodes and including a first repeat node, wherein the first repeat node repeats by sending an element of a message to a path multiple times;

determining a latency between firing of repeats of the first repeat node based on data collected form the first repeat node, wherein the latency comprises a first time;

determining a priority of a first repeat of the first repeat node based on a priority of an incoming message;

weighting the latency for the repeats for the incoming message based on the priority, wherein weighting the latency based on the priority further comprises;

multiplying a first ratio by a delay time to generate a weighted latency having a second time, wherein the first ratio is based on a numerator comprising the priority of the incoming message and a denominator comprising a lowest priority for incoming messages; and

instructing the weighted latency between firing of the repeats of the first repeat node to influence a flow of elements through the first repeat node, and wherein instructing the weighted latency causes the repeat node to delay, by the second time, respective sendings of the element of the incoming message to the path.

13. The system of claim 12, the method further comprising registering the first repeat node for monitoring with a workload manager component.

14. The system of claim 12, wherein the determining the latency is based on an impact of repeats of the first repeat node on applications as determined by data collected from the first repeat node.

15. The system of claim 12, wherein the determining the latency is based on an impact of repeats of the repeat node on components downstream of the integration flow as determined by data collected from the first repeat node.

16. The system of claim 12, wherein data collected from the first repeat node comprises data from resources in the integration flow, and resources in systems effected by the first repeat node.

17. The system of claim 12, wherein data collected from the first repeat node comprises data from applications in the integration flow and application metrics.

18. The system of claim 12, wherein the instructing the weighted latency comprises providing additional code to the first repeat node.

19. The system of claim 12, wherein determining the latency further comprises:

determining that an application is reaching a predefined threshold of performance; and

instructing latencies in repeats of the first repeat node for the application.

20. A computer program product comprising a computer readable storage medium readable by a processing circuit and storing instructions for execution by the processing circuit for performing a method comprising:

managing an integration flow connecting multiple integration nodes and including a first repeat node, wherein the first repeat node repeats by sending an element of a message to a path multiple times;

determining a latency between firing of repeats of the first repeat node based on data collected form the first repeat node, wherein the latency comprises a first time;

determining a priority of a first repeat of the first repeat node based on a priority of an incoming message;

weighting the latency for the repeats for the incoming message based on the priority, wherein weighting the latency based on the priority further comprises;

multiplying a first ratio by a delay time to generate a weighted latency having a second time, wherein the first ratio is based on a numerator comprising the priority of the incoming message and a denominator comprising a lowest priority for incoming messages; and

instructing the weighted latency between firing of the repeats of the first repeat node to influence a flow of elements through the first repeat node, and wherein instructing the weighted latency causes the repeat node to delay, by the second time, respective sendings of the element of the incoming message to the path.