Added the streamer aggregating data at the database instead of Esper.
Code is in bad shape need to implement better design.

Will be the task for next commit.