use multiple consumer workers on ParallelConsumer like BlockingCollectionWorker