Added TestDataGenerator
Added Queue Monitoring
Tested Data Flow
Added some error handling