remote custom filter/splitter/aggregator implementations.
Add event bus based hook support for components.
Update documentation throughout the project.
Update code changes.
Add hook example.
Add basic integration tests.
Remove stream declarations.
Return message correlation IDs from worker emit() methods.
Set integration test timeout to one minute.