def main()

in src/main/scala/com/twitter/iago/util/Adjustor.scala [27:38]


  def main() {
    val newRate = requestRateF()
    val cluster = new ParrotClusterImpl(this)
    val parrots = cluster.connectParrots()
    if (parrots.isEmpty) {
      log.error("Empty Parrots list: do you have access to Zookeeper? (ie, running in SMF1)")
    } else {
      parrots foreach { parrot =>
        parrot.setRate(newRate)
      }
    }
  }