elastic4s_demo.scala

/**
 * Put this in your env (or something similar)
 * ELASTICSEARCH_TOPICS_URL=elasticsearch://localhost:9300,localhost2:9300
 */
 
  /**
   * This is all I need to do to connect using the elasticsearch protocol.
   */
   
  def apply(esHosts: String, clusterName: String): ElasticClient = {
    val settings = ImmutableSettings.settingsBuilder().put("cluster.name", clusterName)
    sys.env.getOrElse("ENV_NAME", "development") match {
      case "production" => ElasticClient.remote(settings.build, ElasticsearchClientUri(esHosts))
      case "staging" => ElasticClient.remote(settings.build, ElasticsearchClientUri(esHosts))
      case "development" => ElasticClient.local
    }
  }