diff options
Diffstat (limited to 'ONAP-PDP/src')
| -rw-r--r-- | ONAP-PDP/src/main/java/org/onap/policy/xacml/action/FindAction.java | 19 |
1 files changed, 17 insertions, 2 deletions
diff --git a/ONAP-PDP/src/main/java/org/onap/policy/xacml/action/FindAction.java b/ONAP-PDP/src/main/java/org/onap/policy/xacml/action/FindAction.java index c6a889821..5fde0adf3 100644 --- a/ONAP-PDP/src/main/java/org/onap/policy/xacml/action/FindAction.java +++ b/ONAP-PDP/src/main/java/org/onap/policy/xacml/action/FindAction.java @@ -240,6 +240,7 @@ public class FindAction { Pattern pattern = Pattern.compile("\\$([a-zA-Z0-9.:]*)"); Matcher match = pattern.matcher(configURL); StringBuffer sb = new StringBuffer(); + JsonReader jsonReader = null; while (match.find()) { LOGGER.info("Found Macro : " + match.group(1)); String replaceValue = matchValues.get(match.group(1)); @@ -292,7 +293,7 @@ public class FindAction { connection = configURL.openConnection(); // InputStream in = connection.getInputStrem(); // LOGGER.info("The Body Content is : " + IOUtils.toString(in)); - JsonReader jsonReader = Json.createReader(connection.getInputStream()); + jsonReader = Json.createReader(connection.getInputStream()); StringEntity input = new StringEntity(jsonReader.readObject().toString()); input.setContentType("application/json"); postRequest.setEntity(input); @@ -312,6 +313,13 @@ public class FindAction { LOGGER.error(e.getMessage() +e); response = e.getMessage(); } finally { + if(jsonReader != null) { + try { + jsonReader.close(); + } catch (Exception e) { + LOGGER.error("Exception Occured while closing the JsonReader"+e); + } + } httpClient.getConnectionManager().shutdown(); } } else if(matchValues.get("method").equalsIgnoreCase("PUT")) { @@ -330,7 +338,7 @@ public class FindAction { connection = configURL.openConnection(); //InputStream in = connection.getInputStream(); //LOGGER.info("The Body Content is : " + IOUtils.toString(in)); - JsonReader jsonReader = Json.createReader(connection.getInputStream()); + jsonReader = Json.createReader(connection.getInputStream()); StringEntity input = new StringEntity(jsonReader.readObject().toString()); input.setContentType("application/json"); putRequest.setEntity(input); @@ -349,6 +357,13 @@ public class FindAction { LOGGER.error(e.getMessage() +e); response = e.getMessage(); }finally { + if(jsonReader != null) { + try { + jsonReader.close(); + } catch (Exception e) { + LOGGER.error("Exception Occured while closing the JsonReader"+e); + } + } httpClient.getConnectionManager().shutdown(); } } |