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)
}
}
}