# US 2017/0257429 A1 · Optimization of integration flows in cloud environments

> Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt

- Number: US 2017/0257429 A1
- Document ID: US20170257429A1
- Status: Published application
- Kind: A1
- Application number: 15/058,511
- Filed: 2016-03-02
- Published: 2017-09-07
- Earliest claimed: 2016-03-02
- Assignees: International Business Machines Corporation
- Applicants: International Business Machines Corporation
- Inventors: John Hosie; Martin A. Ross; Craig H. Stirling; Dominic J. Storey
- Web page: https://patentgrep.com/patent/US20170257429A1

## CPC

- H04L 67/1008: based on parameters of servers, e.g. available memory or workload (monitoring of computer activity G06F11/30)
- H04L 67/101: based on network conditions
- H04L 63/20: {for managing network security; network security policies in general (filtering policies H04L63/0227)}
- H04L: TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION (arrangements common to telegraphic and telephonic communication H04M)

## Abstract

An integration flow is monitored to determine a processing location of a message. The integration flow includes a route, one or more nodes, and one or more secure connectors. A first message is received by the integration flow. A central processing unit serialization load is received including a serialization of the first message on a first secure connector and a deserialization of the first message on a second secure connector. A processing load of the first message running on a first node of the one or more nodes is received. A first threshold of a processing load of the first message is received. The first threshold is determined to have been reached. Based on the first threshold being reached, a processing location of the integration flow is altered such that the first message is processed on a second node of the one or more nodes.

## Claims

### Claim 1

A method comprising:
monitoring an integration flow, the integration flow including a route, one or more nodes, and one or more secure connectors;
receiving a first message;
receiving a central processing unit serialization load including a serialization of the first message on a first secure connector of the one or more secure connectors and a deserialization of the first message on a second secure connector of the one or more secure connectors;
determining a processing load of the first message running on a first node of the one or more nodes;
receiving a first threshold of a processing load of the first message;
determining that the first threshold has been reached; and
altering, based on the first threshold being reached, a processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 2 (depends on 1)

The method of claim 1, wherein the altering further comprises:
serializing the first message at the first secure connector;
transferring the first message to a second operation of the second node;
deserializing the first message at the second secure connector; and
processing the message.

### Claim 3 (depends on 1)

The method of claim 1, wherein the integration flow is hosted on a hybrid cloud environment, and the first node is hosted on an on-premise system, and the second node is hosted on a public cloud.

### Claim 4 (depends on 3)

The method of claim 3, wherein software is provided as a service within the hybrid cloud environment for communicating between source and target applications.

### Claim 5 (depends on 1)

The method of claim 1, wherein the first message is assigned a first priority causing the first message to be processed in the first node.

### Claim 6 (depends on 1)

The method of claim 1, wherein the first threshold of a processing load of the first message is the central processing unit serialization load.

### Claim 7 (depends on 1)

The method of claim 1, wherein receiving the first threshold further comprises:
receiving a second threshold of a total processing load required of the integration flow;
determining that the second threshold of the total processing load has been reached; and
altering, based on the second threshold being reached, the processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 8 (depends on 1)

The method of claim 1, wherein receiving the first threshold further comprises:
receiving a third threshold of a latency for a transfer of the first message;
determining that the third threshold of the latency has been reached; and
altering, based on the third threshold being reached, the processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 9

A system comprising:
a memory;
a processor device communicatively coupled to the memory; and
an hybrid cloud environment communicatively coupled to the processor device and the memory wherein the hybrid could environment is configured to:
monitor an integration flow, the integration flow including a route, one or more nodes, and one or more secure connectors;
receive a first message;
receive a central processing unit serialization load including a serialization of the first message on a first secure connector of the one or more secure connectors and a deserialization of the first message on a second secure connector of the one or more secure connectors;
determine a processing load of the first message running on a first node of the one or more nodes;
receive a first threshold of a processing load of the first message;
determine that the first threshold has been reached; and
alter, based on the first threshold being reached, a processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 10 (depends on 9)

The system of claim 9, wherein the hybrid cloud is further configured to:
serialize the first message at the first secure connector;
transfer the first message to a second operation of the second node;
deserialize the first message at the second secure connector; and
process the message.

### Claim 11 (depends on 9)

The system of claim 9, wherein the integration flow is hosted on the hybrid cloud environment where the first node is hosted on an on-premise system and the second node is hosted on a public cloud.

### Claim 12 (depends on 11)

The system of claim 11, wherein software is provided as a service within the hybrid cloud environment for communicating between source and target applications.

### Claim 13 (depends on 9)

The system of claim 9, wherein the first message is assigned a first priority causing the first message to be processed in the first node.

### Claim 14 (depends on 9)

The system of claim 9, wherein the hybrid cloud environment is further configured to:
receive a second threshold of a total processing load required of the integration flow;
determine that the second threshold of the total processing load has been reached; and
alter, based on the second threshold being reached, the processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 15 (depends on 9)

The system of claim 9, wherein the hybrid cloud environment is further configured to:
receive a third threshold of a latency for a transfer of the first message;
determine that the third threshold of the latency has been reached; and
alter, based on the third threshold being reached, the processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 16

A computer program product for determining processing location of a message comprising a computer readable storage medium having a computer readable application stored therein, wherein the computer readable application, when executed on a computing device, causes the computing device to:
monitor an integration flow, the integration flow including a route, one or more nodes, and one or more secure connectors;
receive a first message;
receive a central processing unit serialization load including a serialization of the first message on a first secure connector of the one or more secure connectors and a deserialization of the first message on a second secure connector of the one or more secure connectors;
determine a processing load of the first message running on a first node of the one or more nodes;
receive a first threshold of a processing load of the first message;
determine that the first threshold has been reached; and
alter, based on the first threshold being reached, a processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 17 (depends on 16)

The computer program product of claim 16, wherein the computing device is further configured to:
serialize the first message at the first secure connector;
transfer the first message to a second operation of the second node;
deserialize the first message at the second secure connector; and
process the message.

### Claim 18 (depends on 16)

The computer program product of claim 16, wherein the first message is assigned a first priority causing the first message to be processed in the first node.

### Claim 19 (depends on 16)

The computer program product of claim 16, wherein the computing device is further configured to:
receive a second threshold of a total processing load required of the integration flow;
determine that the second threshold of the total processing load has been reached; and
alter, based on the second threshold being reached, the processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.

### Claim 20 (depends on 16)

The computer program product of claim 16, wherein the computing device is further configured to:
receive a third threshold of a latency for a transfer of the first message;
determine that the third threshold of the latency has been reached; and
alter, based on the third threshold being reached, the processing location of the integration flow such that the first message is processed on a second node of the one or more nodes.