Create queues in the consumer instead of the reader.
Merge branch 'master' into gofer-1.0