skip

skip function

skip() will evalute the data based on the criteria configured and determine whether the message should continue down the pipeline or be skipped. When evaluating the data, true will result in the message being sent down the pipeline and false will result in the message being skipped. Take a look at the tests for all currently supported configurations. It currently only works for top level fields (i.e. address.street would not work).

configuration

skip({"field": "test", "operator": "==", "match": 10})

example

message in

{
    "_id": 0,
    "name": "transporter",
    "type": "function",
    "count": 10
}

config

skip({"field": "count", "operator": "==", "match": 10})

message out

{
    "_id": 0,
    "name": "transporter",
    "type": "function",
    "count": 10
}

config

skip({"field": "count", "operator": ">", "match": 20})

message would be skipped