You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by cs...@apache.org on 2016/02/17 18:04:29 UTC
karaf-decanter git commit: Allow test to run independently of local
elastic search
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 <ch...@die-schneider.net>
Authored: Wed Feb 17 18:04:16 2016 +0100
Committer: Christian Schneider <ch...@die-schneider.net>
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()));