Added threading for data sources, and data ingester. Added mock tester.