public final void decreaseScheduledWriteMessages(){
  throughputCalculationLock.lock();
  try {
    scheduledWriteMessages--;
  }
  finally {
    throughputCalculationLock.unlock();
  }
}

public final void decreaseScheduledWriteMessages ( ) { throughputCalculationLock . lock ( ) ; try { scheduledWriteMessages -- ; } finally { throughputCalculationLock . unlock ( ) ; } }
decrements the count of messages scheduled for write .
