| CPC G06F 9/546 (2013.01) [G06N 20/00 (2019.01)] | 20 Claims |

|
1. A method, comprising:
collecting message-oriented-middleware system parameters from a plurality of message-oriented-middleware clusters;
analyzing the message-oriented-middleware system parameters using one or more machine learning algorithms;
predicting, based at least in part on the analyzing, at least one anomaly in a message-oriented-middleware cluster of the plurality of message-oriented-middleware clusters;
collecting message metadata from the message-oriented-middleware cluster based, at least in part, on the predicting;
transmitting at least part of the message metadata to one or more remaining ones of the plurality of message-oriented-middleware clusters;
wherein the part of the message metadata corresponds to messaging operations to be transferred from the message-oriented-middleware cluster to the one or more remaining ones of the plurality of message-oriented-middleware clusters, and wherein the part of the message metadata comprises one or more details about progress of message transmission in the message-oriented-middleware cluster, the one or more details including at least one of message offset information and one or more timestamps for messages committed to transmission by the message-oriented-middleware cluster; and
synchronizing, based at least in part on the one or more details about the progress of the message transmission, the messaging operations between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters to prevent message duplication between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters;
wherein the synchronizing comprises translating the message metadata from a format of a first message-oriented-middleware system to a format of a second message-oriented-middleware system to permit the second message-oriented-middleware system to process the one or more details about the progress of the message transmission and prevent re-transmission of the messages committed to transmission by the message-oriented-middleware cluster; and
wherein the steps of the method are executed by a processing device operatively coupled to a memory.
|