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 |
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.
|