US 10,891,615 B1
Transaction exchange platform having streaming transaction data and microservices
Earle Michael Lee, Moseley, VA (US); and William Planck, Midlothian, VA (US)
Assigned to Capital One Services, LLC, McLean, VA (US)
Filed by Capital One Services, LLC, McLean, VA (US)
Filed on Dec. 20, 2019, as Appl. No. 16/723,392.
Int. Cl. G06Q 40/00 (2012.01); G06Q 20/40 (2012.01); G06F 16/23 (2019.01)
CPC G06Q 20/401 (2013.01) [G06F 16/2379 (2019.01)] 30 Claims
OG exemplary drawing
 
1. A computer-implemented method comprising:
receiving a transaction object comprising transaction details and transaction metadata, wherein the transaction metadata comprises:
an indication of a workflow corresponding to a transaction type of the transaction object, wherein the workflow corresponding to the transaction type comprises a plurality of processing steps required to validate a given transaction of the transaction type; and
a current workflow stage of the transaction object;
adding the transaction object to a streaming data platform;
updating the current workflow stage of the transaction object to a first workflow stage;
polling, by a first microservice, the streaming data platform to retrieve transactions matching the first workflow stage, wherein the first workflow stage is associated with the first microservice based on the workflow corresponding to the transaction type;
retrieving, by the first microservice and from the streaming data platform, the transaction object based on the current workflow stage matching the first workflow stage;
processing, by the first microservice, the transaction object;
updating the current workflow stage of the transaction object to a second workflow stage based on completing processing, by the first microservice, of the transaction object;
polling, by a second microservice, the streaming data platform to retrieve transactions matching the second workflow stage, wherein the second workflow stage is associated with the second microservice based on the workflow corresponding to the transaction type;
retrieving, by the second microservice and from the streaming data platform, the transaction object based on the current workflow stage matching the second workflow stage;
processing, by the second microservice, the transaction object;
updating the current workflow stage of the transaction object to a third workflow stage based on completing processing, by the second microservice, of the transaction object;
determining that the current workflow stage of the transaction object indicates that the transaction object has completed processing corresponding to the workflow; and
removing the transaction object from the streaming data platform and outputting the transaction object and an indication that the transaction object has completed the processing corresponding to the workflow.