deduper / org.bradfordmiller.deduper.consumers / BaseConsumer / processQueueData

processQueueData

fun processQueueData(doneFlag: Boolean): Unit

loops over the queue consuming messages until doneFlag is set to true, meaning the last message was empty