refactored stream processing to plugin architecture