Skip to content

Commit 74d00ea

Browse files
committed
adds async factory
1 parent 144e291 commit 74d00ea

File tree

2 files changed

+11
-10
lines changed

2 files changed

+11
-10
lines changed

elasticsearch-driver/src/test/java/org/jnosql/diana/elasticsearch/document/DocumentConfigurationUtils.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,4 +42,13 @@ public static ElasticsearchDocumentCollectionManagerFactory getFactory() {
4242
settings.put("elasticsearch-cluster-name", "elasticsearch");
4343
return configuration.get(Settings.of(settings));
4444
}
45+
46+
public static ElasticsearchDocumentCollectionManagerFactory getFactoryAsync() {
47+
es.start();
48+
ElasticsearchDocumentConfiguration configuration = new ElasticsearchDocumentConfiguration();
49+
Map<String, Object> settings = new HashMap<>();
50+
settings.put("elasticsearch-host-1", es.getContainerIpAddress() + ':' + es.getFirstMappedPort());
51+
settings.put("elasticsearch-cluster-name", "elasticsearch");
52+
return configuration.getAsync(Settings.of(settings));
53+
}
4554
}

elasticsearch-driver/src/test/java/org/jnosql/diana/elasticsearch/document/ElasticsearchDocumentCollectionManagerFactoryTest.java

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -14,30 +14,22 @@
1414
*/
1515
package org.jnosql.diana.elasticsearch.document;
1616

17-
import org.junit.jupiter.api.BeforeEach;
1817
import org.junit.jupiter.api.Test;
1918

2019
import static org.junit.jupiter.api.Assertions.assertNotNull;
2120

2221
public class ElasticsearchDocumentCollectionManagerFactoryTest {
2322

24-
private ElasticsearchDocumentConfiguration configuration;
25-
26-
@BeforeEach
27-
public void setUp() {
28-
configuration = new ElasticsearchDocumentConfiguration();
29-
30-
}
3123

3224
@Test
3325
public void shouldCreateEntityManager() {
34-
ElasticsearchDocumentCollectionManagerFactory factory = configuration.get();
26+
ElasticsearchDocumentCollectionManagerFactory factory = DocumentConfigurationUtils.getFactory();
3527
assertNotNull(factory.get("database"));
3628
}
3729

3830
@Test
3931
public void shouldCreateEntityManagerAsync() {
40-
ElasticsearchDocumentCollectionManagerFactory factory = configuration.getAsync();
32+
ElasticsearchDocumentCollectionManagerFactory factory = DocumentConfigurationUtils.getFactoryAsync();
4133
assertNotNull(factory.getAsync("database"));
4234
}
4335
}

0 commit comments

Comments
 (0)