Fix for Sonar critical issues 63/12363/2
authorrama-huawei <rama.subba.reddy.s@huawei.com>
Thu, 14 Sep 2017 06:08:05 +0000 (11:38 +0530)
committerRama SubbaReddy <rama.subba.reddy.s@huawei.com>
Thu, 14 Sep 2017 08:42:10 +0000 (08:42 +0000)
DCAEGEN2-93

Change-Id: I6218b9c02726591917f8a3ed7b4687acb974b559
Signed-off-by: rama-huawei <rama.subba.reddy.s@huawei.com>
src/main/java/com/att/nsa/mr/client/impl/MRConsumerImpl.java

index fdd1b89..eb7fd91 100644 (file)
@@ -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<String> stringToList ( String str )
        {
                final LinkedList<String> set = new LinkedList<String> ();
@@ -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<String, String> 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;