X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fcom%2Fatt%2Fdmf%2Fmr%2Fresources%2FCambriaOutboundEventStream.java;h=0c7f8bcaf10f9aa88a0df39f5b823d14cc4e584f;hb=a759f919b452d439cbad4ba73f053df30b2d61f9;hp=fd786b7b5dd0b96e4da8ee4297cf9a9e2951b807;hpb=f34c2b80a8b0536c2193a9b45d914b8ca5aa57a8;p=dmaap%2Fmessagerouter%2Fmsgrtr.git

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
--- 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