Address shortcoming in the prototype 

Deliverables:

- Fix outstanding issues in the JVM implementation (if any)
- Implement proper proper periodic flush mechanism 
- Decide on an API 
- Add unit tests for all public methods
- Add JMX support
- Build a graphical client that validate that streaming works, in-process, from a disk repository, and over the network.
- Validate out-of-process consumption in a container environment. 
- Build java agent that validates that streaming can be used to aggregate, filter and relay information upstream