private[this] def connectParrot()

in src/main/scala/com/twitter/iago/util/ParrotCluster.scala [337:355]

• 17 lines of code
• 3 McCabe index (conditional complexity)

  private[this] def connectParrot(host: String, port: Int): Option[RemoteParrot] = {

    val address = new InetSocketAddress(host, port)
    log.info("Connecting to parrot server at %s", address)

    try Some(
      new RemoteParrot(
        new InternalCounter(),
        address,
        config.finagleTimeoutF(),
        config.batchSizeF()
      )
    )
    catch {
      case t: Throwable =>
        log.error(t, "Error connecting to %s: %s", address, t.getMessage)
        None
    }
  }