public final void increaseScheduledWriteMessages(){
  throughputCalculationLock.lock();
  try {
    scheduledWriteMessages++;
  }
  finally {
    throughputCalculationLock.unlock();
  }
}

public final void increaseScheduledWriteMessages ( ) { throughputCalculationLock . lock ( ) ; try { scheduledWriteMessages ++ ; } finally { throughputCalculationLock . unlock ( ) ; } }
increments the count of messages scheduled for write .
