Remove R generic type from ReadStream/WriteStream
- implement basic sender/publiser WriteStream
- provide a body stream on MessageConsumer
Merge pull request #927 from vietj/master

PR for fluent + event bus write stream