diff options
author | 2018-09-20 15:25:47 +0000 | |
---|---|---|
committer | 2018-09-20 15:25:47 +0000 | |
commit | 342a2bdb5ce6c52abb852ca6c4fc85c7a928d027 (patch) | |
tree | 44556f0aae2f26a46ace72d762711e4fe7b9c4c6 /src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java | |
parent | d1eb3b36d9aabe6a754f4d36e6be53ce0cc31848 (diff) | |
parent | a5ee03c6b0f22ca2cc424bcc9ee99cbf94a0d941 (diff) |
Merge changes I61fe5ce8,I89758685,I6b215d2a
* changes:
Sonar Major issues
Sonar Major issues
Sonar Major issues
Diffstat (limited to 'src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java')
-rw-r--r-- | src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java | 38 |
1 files changed, 19 insertions, 19 deletions
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 837c956..86a6ef8 100644 --- a/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java +++ b/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java @@ -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 |