Don't use aggregate data stream concept
Start implementing aggregate data client