fred/logparser
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Var : url to influxdb

Browse Source
This commit is contained in:
Maxime Chassagneux
2016-05-25 17:43:00 +02:00
parent bac738a01c
commit 70285d5ff9
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/airfrance/diqmqs/logparser/ParserEngine.java
View File

@@ -21,6 +21,7 @@ import org.apache.commons.io.input.TailerListener;
public class ParserEngine implements Runnable{ public class ParserEngine implements Runnable{
final private String database = "qualif"; 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; final long delay = 200;
private ArrayList<Thread> threadsParser = null; private ArrayList<Thread> threadsParser = null;
static BlockingDeque<String> queue = new LinkedBlockingDeque<String>(2000); static BlockingDeque<String> queue = new LinkedBlockingDeque<String>(2000);
@@ -96,7 +97,7 @@ public class ParserEngine implements Runnable{
public boolean sendMetricToInfluxdb(String postData) throws IOException { 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(); long start = System.currentTimeMillis();
HttpURLConnection connection = (HttpURLConnection) url.openConnection(); HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setDoOutput(true); connection.setDoOutput(true);