stream processing engine to spool message stream to a file for wot.io