Finagle Clietn Naive Example

FlumeFingleClient

def send[T <: WebLogEvent](event: T) = {
    val client: Service[HttpRequest, HttpResponse] = ClientBuilder()
      .codec(Http())
      .hosts(servers.mkString(","))
      .hostConnectionLimit(10)
      .retries(3)
      .build()

    val request = createFlumeRequest(event)
    val future = client(request)

    future onSuccess { result =>
      result.getStatus match {
        case HttpResponseStatus.OK => logger.debug(s"Event $event accepted by Flume")
        case _ => logger.warn(s"Event haven't been accepted, response: $result")
      }
    } onFailure {
        case f: FailFastException => logger.debug("FailFastException occurred:", f)
        case e: Throwable => e.printStackTrace()
    } ensure {
      client.close()
    }

    future.toJavaFuture
  }