From 620d69f26cbbea1deb5000c7a341e8012a5ad080 Mon Sep 17 00:00:00 2001 From: rb7147 Date: Fri, 16 Jun 2017 14:36:01 -0400 Subject: [Policy-24] Updated the Database Configuration Change-Id: Ie358df4bfef5fb9cfe136f52a9d35f119c55bc97 Signed-off-by: rb7147 --- .../java/org/openecomp/xacml/parser/ParseLog.java | 34 +++++++++++++++------- 1 file changed, 23 insertions(+), 11 deletions(-) (limited to 'LogParser') diff --git a/LogParser/src/main/java/org/openecomp/xacml/parser/ParseLog.java b/LogParser/src/main/java/org/openecomp/xacml/parser/ParseLog.java index 5ddb623c0..73ecf797e 100644 --- a/LogParser/src/main/java/org/openecomp/xacml/parser/ParseLog.java +++ b/LogParser/src/main/java/org/openecomp/xacml/parser/ParseLog.java @@ -141,15 +141,19 @@ public class ParseLog { if (debugfile.isFile()){ // log4jlogger must use .info - try (Stream lines = Files.lines(debugfilePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + debuglastNumberRead)).skip(debuglastNumberRead)) { - + Stream lines = null; + try { + lines = Files.lines(debugfilePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + debuglastNumberRead)).skip(debuglastNumberRead); lines.forEachOrdered(line -> process(line, type, LOGTYPE.DEBUG)); - lines.close(); } catch (IOException e) { logger.error("Error processing line in " + dataFileName + ":" + e); logger.error("break the loop."); isStop = true; - } + }finally{ + if(lines != null){ + lines.close(); + } + } } try { Thread.sleep(sleepTimer); @@ -207,15 +211,19 @@ public class ParseLog { while (!isStop){ if (errorfile.isFile()){ // log4jlogger must use .info - try (Stream lines = Files.lines(errorfilePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + errorlastNumberRead)).skip(errorlastNumberRead)) { - + Stream lines = null; + try{ + lines = Files.lines(errorfilePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + errorlastNumberRead)).skip(errorlastNumberRead); lines.forEachOrdered(line -> process(line, type, LOGTYPE.ERROR)); - lines.close(); } catch (IOException e) { logger.error("Error processing line in " + dataFileName + ":" + e); logger.error("break the loop."); isStop = true; - } + }finally{ + if(lines != null){ + lines.close(); + } + } } try { Thread.sleep(sleepTimer); @@ -271,14 +279,18 @@ public class ParseLog { if (file.isFile()){ // log4jlogger must use .info - try (Stream lines = Files.lines(filePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + lastNumberRead)).skip(lastNumberRead)) { - + Stream lines = null;; + try { + lines = Files.lines(filePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + lastNumberRead)).skip(lastNumberRead); lines.forEachOrdered(line -> process(line, type, LOGTYPE.INFO)); - lines.close(); } catch (IOException e) { logger.error("Error processing line in " + dataFileName + ":" + e); logger.error("break the loop."); isStop = true; + }finally{ + if(lines != null){ + lines.close(); + } } } try { -- cgit 1.2.3-korg