X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=LogParser%2Fsrc%2Fmain%2Fjava%2Forg%2Fopenecomp%2Fxacml%2Fparser%2FParseLog.java;h=73ecf797e77bfeb69704e33d8faa2486f617f43a;hb=620d69f26cbbea1deb5000c7a341e8012a5ad080;hp=5ddb623c06b525c76c5ea7ec8f43ba554e828fb3;hpb=a084c4de015521f842a3fef0d7f1f7c340237bc3;p=policy%2Fengine.git

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<String> lines = Files.lines(debugfilePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + debuglastNumberRead)).skip(debuglastNumberRead)) {
-								
+							Stream<String> 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<String> lines = Files.lines(errorfilePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + errorlastNumberRead)).skip(errorlastNumberRead)) {
-								
+							Stream<String> 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<String> lines = Files.lines(filePath, Charset.defaultCharset()).onClose(() -> log4jlogger.info("Last-"+dataFileName+"-line-Read:" + lastNumberRead)).skip(lastNumberRead)) {
-								
+							Stream<String> 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 {