Renamed old example to pipeline and added new example with a simple dag. Clean code
Bugfixing the multiple streamId path. More robust conn id handling. Better logging output