clean up naming, was too generic
framework for stream processing started