Providing dynamic latency in an integration flow
First Claim
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 from 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; and
instructing the weighted latency between firing of the repeats of the first repeat node, 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.
1 Assignment
0 Petitions
Accused Products
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.
18 Citations
20 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 from 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; and instructing the weighted latency between firing of the repeats of the first repeat node, 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. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13)
-
-
14. 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 from 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; and instructing the weighted latency between firing of the repeats of the first repeat node, 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. - View Dependent Claims (15, 16, 17, 18, 19)
-
-
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 from 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; and instructing the weighted latency between firing of the repeats of the first repeat node, 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.
-
Specification