Message connector as a service to migrate streaming applications into cloud nativity

A system for migrating on-premise streaming applications from on-premise non-cloud infrastructure to target clouds comprising:

• at least one interface for communicating with a cloud message que of target cloud locations;
• at least one interface for communicating with an on-premise message queue for an on-premise streaming application, the at least one interface for communicating with the on-premise message que receives a source message from the on premise streaming application, in which the source message is for transmitting data relevant to the on-premise application to a user that is using the on-premise application;
• and
• a message converter that analyzes the source message for application to at least one of the target cloud locations, wherein analysis includes extracting communication data from the source message and meta data from the source message, the message converter may further provide converting the source message to a format native to the target cloud application, wherein the conversion by the message converter includes a cognitive engine having at least one hardware processor to match a selected target cloud to the on premise message queue based upon at least the meta data.

A computer readable storage medium comprising a computer readable program for migrating on-premise streaming applications from on-premise non-cloud infrastructure to public clouds, wherein the computer readable program when executed on a computer causes the computer to perform the steps of:

• registering target cloud locations with the message connector;
• receiving at a message connector a source message from a message sending and receiving component of an on-premise application, in which the message sending and receiving component of the on-premise application is for transmitting data relevant to the on-premise application to a user that is using the on-premise application;
• analyzing the source message for application to at least one of the target cloud applications, wherein analysis includes extracting communication data from the source message and meta data from the source message;
• converting the source message to a format native to the target cloud application, wherein the conversion by the message connector includes a cognitive engine employing at least one hardware processor to match a selected target cloud to the on-premise application based upon at least the meta data;
• and
• transmitting the source message from the message connector to the target cloud application, wherein the source message has been converted to the format native to the target cloud.