| CPC G06F 9/466 (2013.01) [G06F 9/3005 (2013.01); G06F 9/3555 (2013.01); G06F 9/44505 (2013.01)] | 20 Claims |

|
1. A computer-implemented method comprising:
determining, by a streaming data platform, that processing of a transaction object according to a first workflow, corresponding to a transaction type of the transaction object, did not complete successfully;
determining, by a classification microservice and based on transaction details associated with the transaction object, whether the transaction object comprises information that would allow the transaction object to be processed via a second workflow, wherein the second workflow corresponds to an alternative transaction type and comprises a plurality of processing steps to process a transaction different from a plurality of processing steps associated with the first workflow;
sending, based on a determination that the transaction object can be processed via the second workflow, a request for approval to process the transaction object via the second workflow;
adding, by the classification microservice and based on receiving approval to process the transaction object via the second workflow, the transaction object to the streaming data platform with an indication of the second workflow;
retrieving, by a first microservice, a plurality of transaction objects, wherein the plurality of transaction objects comprises the transaction object;
processing, by the first microservice and based on a determination that a current workflow stage of the transaction object matches a first workflow stage associated with first microservice, the transaction object;
determining that the current workflow stage of the transaction object indicates that the transaction object has completed processing corresponding to the second workflow; and
removing the transaction object from the streaming data platform and outputting the transaction object with an indication that the transaction object has completed the processing corresponding to the second workflow to a downstream system.
|