Repository: karaf-decanter Updated Branches: refs/heads/master cc2d1a140 -> b4a4bbf99
Allow test to run independently of local elastic search Project: http://git-wip-us.apache.org/repos/asf/karaf-decanter/repo Commit: http://git-wip-us.apache.org/repos/asf/karaf-decanter/commit/b4a4bbf9 Tree: http://git-wip-us.apache.org/repos/asf/karaf-decanter/tree/b4a4bbf9 Diff: http://git-wip-us.apache.org/repos/asf/karaf-decanter/diff/b4a4bbf9 Branch: refs/heads/master Commit: b4a4bbf998c3a896221a5d2a35669ed66de92f4c Parents: cc2d1a1 Author: Christian Schneider <[email protected]> Authored: Wed Feb 17 18:04:16 2016 +0100 Committer: Christian Schneider <[email protected]> Committed: Wed Feb 17 18:04:16 2016 +0100 ---------------------------------------------------------------------- .../appender/elasticsearch/TestElasticsearchAppender.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/karaf-decanter/blob/b4a4bbf9/appender/elasticsearch-native-1.x/src/test/java/org/apache/karaf/decanter/appender/elasticsearch/TestElasticsearchAppender.java ---------------------------------------------------------------------- diff --git a/appender/elasticsearch-native-1.x/src/test/java/org/apache/karaf/decanter/appender/elasticsearch/TestElasticsearchAppender.java b/appender/elasticsearch-native-1.x/src/test/java/org/apache/karaf/decanter/appender/elasticsearch/TestElasticsearchAppender.java index 5fd157c..ef8b730 100644 --- a/appender/elasticsearch-native-1.x/src/test/java/org/apache/karaf/decanter/appender/elasticsearch/TestElasticsearchAppender.java +++ b/appender/elasticsearch-native-1.x/src/test/java/org/apache/karaf/decanter/appender/elasticsearch/TestElasticsearchAppender.java @@ -34,17 +34,21 @@ import org.apache.karaf.decanter.api.marshaller.Marshaller; import org.apache.karaf.decanter.marshaller.json.JsonMarshaller; public class TestElasticsearchAppender { + private static final String HOST = "127.0.0.1"; + private static final String CLUSTER_NAME = "elasticsearch-test"; + private static final int PORT = 9301; private static final int MAX_TRIES = 10; @Test public void testAppender() throws Exception { Settings settings = settingsBuilder() - .put("cluster.name", "elasticsearch") + .put("cluster.name", CLUSTER_NAME) .put("http.enabled", "true") .put("node.data", true) .put("path.data", "target/data") - .put("network.host", "127.0.0.1") + .put("network.host", HOST) + .put("port", PORT) .put("index.store.type", "memory") .put("index.store.fs.memory.enabled", "true") .put("path.plugins", "target/plugins") @@ -53,7 +57,7 @@ public class TestElasticsearchAppender { Node node = nodeBuilder().settings(settings).node(); Marshaller marshaller = new JsonMarshaller(); - ElasticsearchAppender appender = new ElasticsearchAppender(marshaller, "127.0.0.1", 9300, "elasticsearch"); + ElasticsearchAppender appender = new ElasticsearchAppender(marshaller, HOST, PORT, CLUSTER_NAME); appender.open(); appender.handleEvent(new Event("testTopic", dummyMap())); appender.handleEvent(new Event("testTopic", dummyMap()));
