Sonar Major issues

[dmaap/messagerouter/msgrtr.git] / src / main / java / com / att / dmf / mr / resources / CambriaOutboundEventStream.java

diff --git a/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java b/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
index fd786b7..0c7f8bc 100644 (file)
--- a/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
+++ b/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
@@ -45,7 +45,7 @@ import com.att.dmf.mr.utils.DMaaPResponseBuilder.StreamWriter;
 import com.att.dmf.mr.utils.Utils;
 import com.att.eelf.configuration.EELFLogger;
 import com.att.eelf.configuration.EELFManager;
-//import com.att.nsa.drumlin.till.nv.rrNvReadable;
+
 /*import com.att.sa.highlandPark.config.HpConfigContext;
 import com.att.sa.highlandPark.config.HpReaderException;
 import com.att.sa.highlandPark.events.HpJsonEvent;
@@ -88,7 +88,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
                private boolean fWithMeta;
                ArrayList<Consumer> fKafkaConsumerList;
 
-               // private int fOffset;
+               
                /**
                 * constructor it initializes all the consumer parameters
                 * 
@@ -97,15 +97,15 @@ public class CambriaOutboundEventStream implements StreamWriter {
                 */
                public Builder(Consumer c) {
                        this.fConsumer = c;
-                       // this.fSettings = settings;
+                       
 
                        fLimit = CambriaConstants.kNoTimeout;
                        fTimeoutMs = CambriaConstants.kNoLimit;
                        fTopicFilter = CambriaConstants.kNoFilter;
                        fPretty = false;
                        fWithMeta = false;
-                       //this.fKafkaConsumerList = consList;
-                       // fOffset = CambriaEvents.kNextOffset;
+                       
+       
                }
 
                /**
@@ -172,7 +172,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
 
                // public Builder atOffset ( int pos )
                
-               // fOffset = pos;
+       
                // return this;
                // }
                /**
@@ -264,7 +264,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
         */
        public void write(final OutputStream os) throws IOException {
                
-               // final boolean transactionEnabled = isTransEnabled();
+       
                // final boolean transactionEnabled = istransEnable;
                // synchronized(this){
                os.write('[');
@@ -479,10 +479,10 @@ public class CambriaOutboundEventStream implements StreamWriter {
         * 
         * Checks whether filter is initialized
         */
-       /*private boolean isFilterInitialized() {
-               return (fHpAlarmFilter != null && fHppe != null);
-       }
-*/
+       
+               
+       
+
        /**
         * 
         * @param msg
@@ -490,18 +490,18 @@ public class CambriaOutboundEventStream implements StreamWriter {
         */
        private boolean filterMatches(String msg) {
                boolean result = true;
-               /*if (isFilterInitialized()) {
-                       try {
-                               final HpJsonEvent e = new HpJsonEvent("e", new JSONObject(msg));
-                               result = fHpAlarmFilter.matches(fHppe, e);
-                       } catch (JSONException x) {
-                               // the msg may not be JSON
-                               result = false;
-                               log.error("Failed due to " + x.getMessage());
-                       } catch (Exception x) {
-                               log.error("Error using filter: " + x.getMessage(), x);
-                       }
-               }*/
+               
+               
+                               
+                               
+                       
+                       
+                       
+                               
+                       
+                               
+               
+       
 
                return result;
        }
@@ -534,11 +534,11 @@ public class CambriaOutboundEventStream implements StreamWriter {
        private final Consumer fConsumer;
        private final int fLimit;
        private final int fTimeoutMs;
-       // private final rrNvReadable fSettings;
+       
        private final boolean fPretty;
        private final boolean fWithMeta;
        private int fSent;
-//     private final HpAlarmFilter<HpJsonEvent> fHpAlarmFilter;
+
        //private final HpProcessingEngine<HpJsonEvent> fHppe;
        private DMaaPContext dmaapContext;
        private String responseTransactionId;
@@ -548,7 +548,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
        private ArrayList<Consumer> fKafkaConsumerList;
        private boolean istransType = true;
        // private static final Logger log =
-       // Logger.getLogger(CambriaOutboundEventStream.class);
+       
 
        private static final EELFLogger log = EELFManager.getInstance().getLogger(CambriaOutboundEventStream.class);
 }
\ No newline at end of file