US 12,216,659 B2
System and method to support in-order message processing with reactive microservices
Michael Barnes, Doylestown, PA (US); Ashutosh P. Nanekar, Cary, NC (US); Dominique Prunier, Montreal (CA); Daniel A. Lottero, Milford, MA (US); and Kshitij Patel, Cary, NC (US)
Filed by Dell Products L.P., Round Rock, TX (US)
Filed on May 2, 2023, as Appl. No. 18/142,139.
Prior Publication US 2024/0370444 A1, Nov. 7, 2024
Int. Cl. G06F 16/2455 (2019.01); G06F 16/2453 (2019.01); H04L 67/55 (2022.01); H04L 67/562 (2022.01)
CPC G06F 16/24568 (2019.01) [G06F 16/24542 (2019.01); H04L 67/55 (2022.05); H04L 67/562 (2022.05)] 20 Claims
OG exemplary drawing
 
1. A computer-implementable method for processing in-order messages comprising:
performing in-order messaging within a message broker with unique message keys that ensure each batch of messages are sent on the same message broker partition;
providing through a reactive generic data streaming processor, parallel data stream uniquely grouped to each message broker partition by implementing coding precautions through concatMap to maintain the parallel data stream, wherein order is preserved through a key that includes SystemID and data objectType;
maintaining in-order processing on each parallel data stream by using downstream publishers that preserve strict order in each data stream; and
providing a terminal sync message with a unique message key to identify end of in-order streaming a message group.