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