DeduperDupeConsumer(dupePersistor: DupePersistor, dupeQueue: BlockingQueue<MutableList<Pair<String, Pair<MutableList<Long>, Dupe>>>>, controlQueue: ArrayBlockingQueue<DedupeReport>, deleteDupeIfExists: Boolean)
Consumer for processing and persisting duplicate data