Any¶
This plugin takes a list of filters and applies each of them to incoming messages until a an accepting filter is found. If any of the listed filters accept the message, it is passed through, otherwise, the message is dropper.
Parameters¶
AnyFilters
Defines a list of filters that should be checked before filtering a message. Filters are checked in order, and if the message passes then no further filters are checked.
Parameters (from core.SimpleFilter)¶
FilteredStream
This value defines the stream filtered messages get sent to. You can disable this behavior by setting the value to “”. By default this parameter is set to “”.
Examples¶
This example will accept valid json or messages from “exceptionStream”:
ExampleConsumer:
Type: consumer.Console
Streams: "*"
Modulators:
- filter.Any:
AnyFilters:
- filter.JSON
- filter.Stream:
Only: exceptionStream