int [] corruptIndexList = input.getCorruptIndexList();
if (corruptIndexList.length > 0)
{
tEmitter.join(emitterWaitms);
EventCorruptionType corruptionType = input.getCorruptionType();
eventProducer.tarnishEventsInBuffer(corruptIndexList, corruptionType);
}
//start consumer / reader /writer
tConsumer.start();
tWriter.start();