KafkaSink, added shutdown to KafkaSource
RMQ Sink for other types
RMQ source for multiple types
rmq source refactored
kafka sink and source for multiple types
addons rename to connectors
addons rename to connectors
remove legacy source folder
explicit output flushing removed from streamcollector
Merge branch 'master' of https://github.com/stratosphere/stratosphere-streaming
addon packages rename to connector
Merge branch 'master' of https://github.com/stratosphere/stratosphere-streaming
merge
merge
explicit output flushing readded + need fix
Merge branch 'master' into intern
whatever
Merge branch 'intern' of https://github.com/stratosphere/stratosphere-streaming into intern
Updated RemoteStreamEnvironment
Merge branch 'master' of https://github.com/stratosphere/stratosphere-streaming