Pipeline only work on "all messages" stream

the field source is mandatory, if the pipeline did not work, you might have entries in your server.log.