uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ProducerThread.java [76:83]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      ConsumerIterator incomeData,
      IMessageTransformer messageTransformer,
      ICheckPointManager checkpointManager,
      WorkerInstance workerInstance) {
    this.messageTransformer = messageTransformer;
    this.checkpointManager = checkpointManager;
    this.incomeData = incomeData;
    this.workerInstance = workerInstance;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/ProducerThread.java [103:110]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      ConsumerIterator incomeData,
      IMessageTransformer messageTransformer,
      ICheckPointManager checkpointManager,
      WorkerInstance workerInstance) {
    this.messageTransformer = messageTransformer;
    this.checkpointManager = checkpointManager;
    this.incomeData = incomeData;
    this.workerInstance = workerInstance;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -