Hack pipeline

Rough draft of the real-time pipelines.
Yeah, it used to be str, but I changed it to object as that was easier.  While writing this the first variable morphed from 'message' -> 'index'