Create queues in the consumer instead of the reader.