From: rama-huawei Date: Thu, 14 Sep 2017 06:08:05 +0000 (+0530) Subject: Fix for Sonar critical issues X-Git-Tag: v1.0.0~22^2 X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F63%2F12363%2F2;p=dmaap%2Fmessagerouter%2Fdmaapclient.git Fix for Sonar critical issues DCAEGEN2-93 Change-Id: I6218b9c02726591917f8a3ed7b4687acb974b559 Signed-off-by: rama-huawei --- diff --git a/src/main/java/com/att/nsa/mr/client/impl/MRConsumerImpl.java b/src/main/java/com/att/nsa/mr/client/impl/MRConsumerImpl.java index fdd1b89..eb7fd91 100644 --- a/src/main/java/com/att/nsa/mr/client/impl/MRConsumerImpl.java +++ b/src/main/java/com/att/nsa/mr/client/impl/MRConsumerImpl.java @@ -57,7 +57,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer private static final String SUCCESS_MESSAGE = "Success"; - private Logger fLog = LoggerFactory.getLogger ( this.getClass().getName () ); + private Logger log = LoggerFactory.getLogger ( this.getClass().getName () ); public static List stringToList ( String str ) { final LinkedList set = new LinkedList (); @@ -160,6 +160,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer { // unexpected response reportProblemWithResponse (); + log.error("exception: ", e); } catch ( HttpException e ) { @@ -202,6 +203,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer { // unexpected response reportProblemWithResponse (); + log.error("exception: ", e); } catch ( HttpException e ) { @@ -242,6 +244,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer { // unexpected response reportProblemWithResponse (); + log.error("exception: ", e); } catch ( HttpException e ) { @@ -253,6 +256,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer } catch ( JSONException e ) { // unexpected response reportProblemWithResponse (); + log.error("exception: ", e); } catch (HttpException e) { throw new IOException(e); } catch (Exception e ) { @@ -267,7 +271,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer try { - //fLog.info("DMAAP response status: " + response.getStatus()); + //log.info("DMAAP response status: " + response.getStatus()); // final String responseData = response.readEntity(String.class); JSONTokener jsonTokener = new JSONTokener(response); @@ -284,7 +288,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer return jsonObject; } catch (JSONException excp) { - // fLog.error("DMAAP - Error reading response data.", excp); + // log.error("DMAAP - Error reading response data.", excp); return null; } @@ -348,7 +352,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer private Properties props; private HashMap DMETimeOuts; private String handlers; - public static String routerFilePath; + public static final String routerFilePath = null; public static String getRouterFilePath() { return routerFilePath; } @@ -413,7 +417,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer url = protocol + "://"+serviceName+"?version="+version+"&envContext="+env+"&routeoffer="+routeOffer; } - //fLog.info("url :"+url); + //log.info("url :"+url); if(timeoutMs != -1 )url=url+"&timeout="+timeoutMs; if(limit != -1 )url=url+"&limit="+limit; @@ -564,7 +568,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer MRClientFactory.prop.load(new FileReader(new File (MRClientFactory.routeFilePath))); } catch (Exception ex) { - fLog.error("Reply Router Error " + ex.toString() ); + log.error("Reply Router Error " + ex.toString() ); } String routeOffer = MRClientFactory.prop.getProperty(routeKey); return routeOffer; @@ -669,15 +673,19 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer } catch (JSONException e) { mrConsumerResponse.setResponseMessage(String.valueOf(HttpStatus.SC_INTERNAL_SERVER_ERROR)); mrConsumerResponse.setResponseMessage(e.getMessage()); + log.error("json exception: ", e); } catch (HttpException e) { mrConsumerResponse.setResponseMessage(String.valueOf(HttpStatus.SC_INTERNAL_SERVER_ERROR)); mrConsumerResponse.setResponseMessage(e.getMessage()); + log.error("http exception: ", e); }catch(DME2Exception e){ mrConsumerResponse.setResponseCode(e.getErrorCode()); mrConsumerResponse.setResponseMessage(e.getErrorMessage()); + log.error("DME2 exception: ", e); }catch (Exception e) { mrConsumerResponse.setResponseMessage(String.valueOf(HttpStatus.SC_INTERNAL_SERVER_ERROR)); mrConsumerResponse.setResponseMessage(e.getMessage()); + log.error("exception: ", e); } mrConsumerResponse.setActualMessages(msgs); return mrConsumerResponse;