Optimization of integration flows in cloud environments

A system comprising:

• a memory;
• a processor device communicatively coupled to the memory;
• and
• a 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, wherein the one or more nodes and the one or more secure connectors are computing resources in a shared pool of configurable computing resources;
• receive a first message;
• receive a central processing unit (CPU) serialization load, the CPU serialization load comprising a set of processing data, the set of processing data reflecting the amount of a CPU processing load required to serialize and deserialize the first message on-premise;
• receive a first threshold of the CPU processing load of the first message, wherein the processing load is selected from one of the group consisting of:
• a CPU serialization load of the first message and a ratio of CPU serialization load to CPU processing load of the first message;
• determine that the set of processing data is below the first threshold;
• alter, based on the determining, a processing location of the integration flow at a second node of the one or more nodes, wherein the second node is hosted on a public cloud;
• transmit, for processing, the first message to the second node;
• receive a message property of the first message;
• query a database of historical data for a plurality of previous messages having the same message property;
• determine that the plurality of previous messages was processed on a third node of the one or more nodes;
• and
• alter, based on the message property, the processing location of the integration flow such that the first message is processed on the third node.

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, wherein the one or more nodes and the one or more secure connectors are computing resources in a shared pool of configurable computing resources;
• receive a first message;
• receive a central processing unit (CPU) serialization load, the CPU serialization load comprising a set of processing data, the set of processing data reflecting the amount of a CPU processing load required to serialize and deserialize the first message on-premise;
• receive a first threshold of the CPU processing load of the first message, wherein the processing load is selected from one of the group consisting of:
• a CPU serialization load of the first message and a ratio of CPU serialization load to CPU processing load of the first message;
• determine that the set of processing data is below the first threshold;
• alter, based on the determining, a processing location of the integration flow at a second node of the one or more nodes, wherein the second node is hosted on a public cloud;
• transmitting, for processing, the first message to the second node;
• receive a message property of the first message;
• query a database of historical data for a plurality of previous messages having the same message property;
• determine that the plurality of previous messages was processed on a third node of the one or more nodes;
• and
• alter, based on the message property, the processing location of the integration flow such that the first message is processed on the third node.