def shutdown()

in src/main/scala/com/twitter/iago/util/ParrotCluster.scala [385:400]

• 15 lines of code
• 5 McCabe index (conditional complexity)

  def shutdown() {
    log.logLazy(Level.DEBUG, "ParrotClusterImpl: shutting down")
    if (config.zkHostNameF() != "?") discovery.shutdown()

    val allParrots = parrots
    allParrots foreach { parrot =>
      try {
        parrot.shutdown()
        log.info("connection to parrot server %s successfully shut down".format(parrot.address))
      } catch {
        case t: Throwable => log.error(t, "Error shutting down Parrot: %s", t.getClass.getName)
      }
    }
    _runningParrots.clear()
    _pausedParrots.clear()
  }