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

Change somes logs to debug

Browse Source
This commit is contained in:
Maxime Chassagneux
2017-08-25 13:12:45 +02:00
parent 38e5805941
commit 03b6b322d2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -84,7 +84,7 @@ public class ParserEngine implements Runnable {
// Read data from the Queue and send it to influxdb // Read data from the Queue and send it to influxdb
public void run() { public void run() {
StringBuilder postData = new StringBuilder(); StringBuilder postData = new StringBuilder();
log.info("Actual queue size " + queue.size()); log.debug("Actual queue size " + queue.size());
int nbElement = queue.drainTo(res, 2000); int nbElement = queue.drainTo(res, 2000);
if (nbElement > 0) { if (nbElement > 0) {
for (String s : res) { for (String s : res) {
@@ -123,7 +123,7 @@ public class ParserEngine implements Runnable {
// Write data // Write data
OutputStream os = connection.getOutputStream(); OutputStream os = connection.getOutputStream();
log.info("Message to send : \n" + postData); log.debug("Message to send : \n" + postData);
os.write(postData.getBytes()); os.write(postData.getBytes());
int HttpResult = connection.getResponseCode(); int HttpResult = connection.getResponseCode();
long end = System.currentTimeMillis(); long end = System.currentTimeMillis();