Fixes up both sides of the raw-data queue

Using 2 threads we now read the data in and push it through the raw-data
queue. The value convertors pull the values down. We will next add a new
delegate type which will convert the values appropriately and push them
off to be persisted / distributed.