Added integrator. Testing passage of queues between threads.