having collection of batches as a Blocking queue in SeqFileWRabbit could be causing issues.