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
AssigneeSalesforce, Inc.
InventorsSteven Joseph Crouse, Charles Cox
Life of this patent
Estimating the term…
Abstract
Methods and systems are provided 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.
Claims20
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.
A system comprising at least one hardware-based processor and memory, wherein the memory comprises processor-executable instructions encoded on a non-transitory processor-readable media, wherein the processor-executable instructions, when executed by the hardware-based processor, cause the system to:
- provide a plurality of declaratively-defined, code-based validation rules that are to be applied to validate a stream of incoming messages from a specific input message source to a 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
- provide, 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.
A non-transitory, computer-readable medium containing instructions thereon for processing a stream of incoming messages sent from a specific input message source and validating each incoming message of that stream before sending processed message results to a specific target system, wherein the instructions, which, when executed by one or more hardware processors are configurable to perform a 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.
Dependencies are inferred from the claim text.