VoltDB Client Provider for Guice

VoltDbClientProvider.scala

class VoltDbClientProvider @Inject()(settings: AppSettings) extends Provider[Client] {
  val cf = settings.getSection("voltdb")
  val nodes = cf.getConfigList("nodes").toList

  var client: Option[Client] = None

  private val executor = Executors.newCachedThreadPool(new ThreadFactory() {
    def newThread(runnable: Runnable): Thread = {
      val thread = new Thread(runnable, "Retry Connection")
      thread.setDaemon(true)
      thread
    }
  })

  val clientConfig = new ClientConfig(cf.getString("username"), cf.getString("password"), new ClientStatusListenerExt {
    override def connectionLost(hostname: String, port: Int, connectionsLeft: Int, cause: DisconnectCause) = {
      client match {
        case Some(c) =>
          executor.execute(new Runnable {
            override def run() = connectToHosts(c, (hostname, port))
          })
      }
    }
  })

  def connectToHosts(client: Client, hosts: (String, Int)*) {
    hosts.foreach {
      case (h: String, p: Int) =>
        client.createConnection(h, p)
    }

  }

  def get() = {
    client = Some(ClientFactory.createClient(clientConfig))
    val hosts = nodes.map(n => (n.getString("host"), n.getInt("port")))
    connectToHosts(client.get, hosts: _*)
    client.get
  }


}