From 70285d5ff9a5a8c062f10b87d294ade04045ce9b Mon Sep 17 00:00:00 2001 From: Maxime Chassagneux <4163013@airfrance.fr> Date: Wed, 25 May 2016 17:43:00 +0200 Subject: [PATCH] Var : url to influxdb --- src/main/java/com/airfrance/diqmqs/logparser/ParserEngine.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/airfrance/diqmqs/logparser/ParserEngine.java b/src/main/java/com/airfrance/diqmqs/logparser/ParserEngine.java index c6955c9..1316f7a 100644 --- a/src/main/java/com/airfrance/diqmqs/logparser/ParserEngine.java +++ b/src/main/java/com/airfrance/diqmqs/logparser/ParserEngine.java @@ -21,6 +21,7 @@ import org.apache.commons.io.input.TailerListener; public class ParserEngine implements Runnable{ final private String database = "qualif"; + final private String urlInfluxdb = "http://diqmqs.airfrance.fr/influxdb_query/write?rp=one_week&db=" + database; final long delay = 200; private ArrayList threadsParser = null; static BlockingDeque queue = new LinkedBlockingDeque(2000); @@ -96,7 +97,7 @@ public class ParserEngine implements Runnable{ public boolean sendMetricToInfluxdb(String postData) throws IOException { - URL url = new URL("http://diqmqs.airfrance.fr/influxdb_query/write?rp=one_week&db=" + database); + URL url = new URL(urlInfluxdb); long start = System.currentTimeMillis(); HttpURLConnection connection = (HttpURLConnection) url.openConnection(); connection.setDoOutput(true);