US 12,001,898 B2
Method and system for processing a stream of incoming messages sent from a specific input message source and validating each incoming message of that stream before sending them to a specific target system
Steven Joseph Crouse, Halifax, CA (US); and Charles Cox, Halifax, CA (US)
Assigned to Salesforce, Inc.
Filed by Salesforce, Inc., San Francisco, CA (US)
Filed on Nov. 30, 2022, as Appl. No. 18/060,417.
Application 18/060,417 is a continuation of application No. 17/446,590, filed on Aug. 31, 2021, granted, now 11,544,125.
Application 17/446,590 is a continuation of application No. 16/259,826, filed on Jan. 28, 2019, granted, now 11,157,337, issued on Oct. 26, 2021.
Prior Publication US 2023/0168955 A1, Jun. 1, 2023
This patent is subject to a terminal disclaimer.
Int. Cl. G06F 9/54 (2006.01); H04L 51/212 (2022.01)
CPC G06F 9/546 (2013.01) [G06F 9/544 (2013.01); H04L 51/212 (2022.05); G06F 2209/547 (2013.01); G06F 2209/548 (2013.01)] 20 Claims
OG exemplary drawing
 
1. A method for processing a stream of incoming messages sent from a specific input message source and validating each incoming message of that stream at run-time via a declarative stream processing pipeline before sending processed message results to a specific target system, the method comprising:
providing a plurality of declaratively-defined, code-based validation rules that are to be applied to validate the stream of incoming messages from the specific input message source to the specific target system, wherein each of the plurality of declaratively-defined, code-based validation rules are declaratively-defined to specify a rule that an incoming message must comply with to be successfully validated; and
providing, at run-time, the plurality of declaratively-defined, code-based validation rules based on a message schema and a payload criterion for validation by a consumer;
wherein the schema comprises a field identification and a field value definition for use by the consumer.