2017-12-25 5 views
1

Meine Anwendung sollte einen ES-Server, ich meine einen lokalen Knoten, in den Tests starten. Der Client sollte ein HttpClient sein.ElasticSearch Test HTTP-Client

val clusterName: String = "getting-started-with-elastic4s" 
val homePath: Path = Files.createTempDirectory(clusterName) 
val localNode = LocalNode(clusterName,homePath.toAbsolutePath.toString) 
localNode.start() 
val client = HttpClient(ElasticsearchClientUri("localhost",9200)) 
client.execute{ 
    createIndex("trial") 
}.await 

Es wird Timeout. Was ist falsch?

Antwort

0

Es gibt keine Garantie, dass der Port wird 9200. Es ist in der Regel ist aber vielleicht etwas anderes hat diesen Port genommen. Sie sollten den HTTP-Client vom lokalen Knoten selbst generieren.

val clusterName = "getting-started-with-elastic4s" 
    val homePath = Files.createTempDirectory(clusterName) 
    val localNode = LocalNode(clusterName, homePath.toAbsolutePath.toString) 
    localNode.start() 

    val client = localNode.http(true) 
    val resp = client.execute { 
    createIndex("trial") 
    }.await 
    println(resp) 
+0

Ich benutze 5,5. Dieser HTTP Anruf ist in 6.0 Ich denke, –

+0

Sollte in 5.5 auch sein. – monkjack