Streaming queues and starting work for tests.