aboutsummaryrefslogtreecommitdiffstats
path: root/common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java
diff options
context:
space:
mode:
Diffstat (limited to 'common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java')
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java95
1 files changed, 48 insertions, 47 deletions
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java
index b43dca45..58db1da4 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java
@@ -1,8 +1,8 @@
-/*-
+/*
* ============LICENSE_START=======================================================
* ONAP-Logging
* ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -20,12 +20,9 @@
package org.onap.policy.common.logging.eelf;
-import org.slf4j.MDC;
-
import static org.onap.policy.common.logging.eelf.Configuration.*;
import org.onap.policy.common.logging.flexlogger.LoggerType;
-import org.onap.policy.common.logging.eelf.PolicyLogger;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFLogger.Level;
import com.att.eelf.configuration.EELFManager;
@@ -43,7 +40,9 @@ import java.util.Properties;
import java.util.Timer;
import java.util.TimerTask;
import java.util.UUID;
-import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+
+import org.slf4j.MDC;
/**
*
@@ -63,6 +62,8 @@ public class PolicyLogger {
private static EELFLogger debugLogger = EELFManager.getInstance()
.getDebugLogger();
+
+ private static final String POLICY_LOGGER = "PolicyLogger";
private static EventTrackInfo eventTracker = new EventTrackInfo();
@@ -95,7 +96,7 @@ public class PolicyLogger {
private static Level auditLevel = Level.INFO;
private static Level metricsLevel = Level.INFO;
private static Level errorLevel = Level.ERROR;
- private static String CLASS_NAME = "ClassName";
+ private static String classNameProp = "ClassName";
private static final String DATE_FORMAT = "yyyy-MM-dd'T'HH:mm:ss.SSS+00:00";
private static final String COMPLETE_STATUS = "COMPLETE";
@@ -107,7 +108,7 @@ public class PolicyLogger {
hostName = InetAddress.getLocalHost().getHostName();
hostAddress = InetAddress.getLocalHost().getHostAddress();
} catch (UnknownHostException e) {
- PolicyLogger.error(MessageCodes.EXCEPTION_ERROR, e, "PolicyLogger", "UnknownHostException");
+ PolicyLogger.error(MessageCodes.EXCEPTION_ERROR, e, POLICY_LOGGER, "UnknownHostException");
}
}
}
@@ -145,11 +146,11 @@ public class PolicyLogger {
}
public static String getClassname() {
- return CLASS_NAME;
+ return classNameProp;
}
public static synchronized void setClassname(String name) {
- CLASS_NAME = name;
+ classNameProp = name;
}
/**
@@ -184,7 +185,7 @@ public class PolicyLogger {
MDC.put(MDC_SERVER_FQDN, hostName);
MDC.put(MDC_SERVER_IP_ADDRESS, hostAddress);
} catch (Exception e) {
- errorLogger.error(MessageCodes.EXCEPTION_ERROR, e, "PolicyLogger");
+ errorLogger.error(MessageCodes.EXCEPTION_ERROR, e, POLICY_LOGGER);
}
Instant startTime = Instant.now();
Instant endTime = Instant.now();
@@ -225,7 +226,7 @@ public class PolicyLogger {
MDC.put(MDC_KEY_REQUEST_ID, transId);
if(mdcInfo != null && mdcInfo.getMDCInfo() != null && !mdcInfo.getMDCInfo().isEmpty()){
- ConcurrentHashMap<String, String> mdcMap = mdcInfo.getMDCInfo();
+ ConcurrentMap<String, String> mdcMap = mdcInfo.getMDCInfo();
Iterator<String> keyIterator = mdcMap.keySet().iterator();
String key;
@@ -239,7 +240,7 @@ public class PolicyLogger {
MDC.put(MDC_SERVER_FQDN, hostName);
MDC.put(MDC_SERVER_IP_ADDRESS, hostAddress);
} catch (Exception e) {
- errorLogger.error(MessageCodes.EXCEPTION_ERROR, e, "PolicyLogger");
+ errorLogger.error(MessageCodes.EXCEPTION_ERROR, e, POLICY_LOGGER);
}
Instant startTime = Instant.now();
Instant endTime = Instant.now();
@@ -336,7 +337,7 @@ public class PolicyLogger {
MDC.put(MDC_SERVER_FQDN, hostName);
MDC.put(MDC_SERVER_IP_ADDRESS, hostAddress);
} catch (Exception e) {
- errorLogger.error(MessageCodes.EXCEPTION_ERROR, e, "PolicyLogger");
+ errorLogger.error(MessageCodes.EXCEPTION_ERROR, e, POLICY_LOGGER);
}
MDC.put(MDC_INSTANCE_UUID, "");
MDC.put(MDC_ALERT_SEVERITY, "");
@@ -363,7 +364,7 @@ public class PolicyLogger {
* @param arguments
*/
public static void info(MessageCodes msg, String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.info(msg, arguments);
}
@@ -374,7 +375,7 @@ public class PolicyLogger {
* @param arguments
*/
public static void info(MessageCodes msg, String className, String... arguments) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
debugLogger.info(msg, arguments);
}
@@ -384,7 +385,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void info( String className, String arg0) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
debugLogger.info(MessageCodes.GENERAL_INFO, arg0);
}
@@ -394,7 +395,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void info(Object arg0) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.info(MessageCodes.GENERAL_INFO, String.valueOf(arg0));
}
@@ -406,7 +407,7 @@ public class PolicyLogger {
*/
public static void info(MessageCodes msg, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
String arguments2 = getNormalizedStackTrace(arg0, arguments);
debugLogger.info(msg, arguments2);
}
@@ -420,7 +421,7 @@ public class PolicyLogger {
*/
public static void info(MessageCodes msg, String className, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
String arguments2 = getNormalizedStackTrace(arg0, arguments);
debugLogger.info(msg, arguments2);
}
@@ -431,7 +432,7 @@ public class PolicyLogger {
* @param className class name
*/
public static void warn( String className, String arg0) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
debugLogger.warn(MessageCodes.GENERAL_INFO, arg0);
}
@@ -440,7 +441,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void warn(Object arg0) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.warn(MessageCodes.GENERAL_WARNING, "" + arg0);
}
@@ -449,7 +450,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void warn(String arg0) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.warn(MessageCodes.GENERAL_WARNING, arg0);
}
@@ -459,7 +460,7 @@ public class PolicyLogger {
* @param arguments
*/
public static void warn(MessageCodes msg, String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.warn(msg, arguments);
}
@@ -470,7 +471,7 @@ public class PolicyLogger {
* @param arguments
*/
public static void warn(MessageCodes msg, String className, String... arguments) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
debugLogger.warn(msg, arguments);
}
@@ -482,7 +483,7 @@ public class PolicyLogger {
*/
public static void warn(MessageCodes msg, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
String arguments2 = getNormalizedStackTrace(arg0, arguments);
debugLogger.warn(msg, arguments2);
}
@@ -496,7 +497,7 @@ public class PolicyLogger {
*/
public static void warn(MessageCodes msg, String className, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
String arguments2 = getNormalizedStackTrace(arg0, arguments);
debugLogger.warn(msg, arguments2);
}
@@ -507,7 +508,7 @@ public class PolicyLogger {
* @param arg0 log message
*/
public static void error( String className, String arg0) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
if(ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR) != null){
MDC.put(ERROR_CODE, ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR).getErrorCode());
MDC.put(ERROR_DESCRIPTION, ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR).getErrorDesc());
@@ -521,7 +522,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void error(String arg0) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR) != null){
@@ -537,7 +538,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void error(Object arg0) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR) != null){
@@ -556,7 +557,7 @@ public class PolicyLogger {
*/
public static void error(MessageCodes msg, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(msg) != null){
@@ -577,7 +578,7 @@ public class PolicyLogger {
*/
public static void error(MessageCodes msg, String className, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(msg) != null){
@@ -595,7 +596,7 @@ public class PolicyLogger {
* @param arguments
*/
public static void error(MessageCodes msg, String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(msg) != null){
@@ -612,7 +613,7 @@ public class PolicyLogger {
* @param arguments
*/
public static void debug(MessageCodes msg, String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.debug(msg, arguments);
}
@@ -622,7 +623,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void debug( String className, String arg0) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
debugLogger.debug(MessageCodes.GENERAL_INFO, arg0);
}
@@ -631,7 +632,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void debug(String arg0) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.debug(arg0);
}
@@ -641,7 +642,7 @@ public class PolicyLogger {
*/
public static void debug(Object arg0) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.debug("" + arg0);
}
@@ -652,7 +653,7 @@ public class PolicyLogger {
*/
public static void audit(String className, Object arg0) {
MDC.put(STATUS_CODE, COMPLETE_STATUS);
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
auditLogger.info("" + arg0);
}
@@ -662,7 +663,7 @@ public class PolicyLogger {
*/
public static void audit(Object arg0) {
MDC.put(STATUS_CODE, COMPLETE_STATUS);
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
auditLogger.info("" + arg0);
}
@@ -674,7 +675,7 @@ public class PolicyLogger {
*/
public static void debug(MessageCodes msg, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
String arguments2 = getNormalizedStackTrace(arg0, arguments);
errorLogger.error(msg, arguments2);
}
@@ -688,7 +689,7 @@ public class PolicyLogger {
*/
public static void debug(MessageCodes msg, String className, Throwable arg0,
String... arguments) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
String arguments2 = getNormalizedStackTrace(arg0, arguments);
errorLogger.error(msg, arguments2);
}
@@ -746,7 +747,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void trace( String className, String arg0) {
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
errorLogger.info(MessageCodes.GENERAL_INFO, arg0);
}
@@ -756,7 +757,7 @@ public class PolicyLogger {
*/
public static void trace(Object arg0){
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
debugLogger.trace(""+arg0);
}
/**
@@ -1012,7 +1013,7 @@ public class PolicyLogger {
seTimeStamps();
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
String serviceName = MDC.get(MDC_SERVICE_NAME);
MDC.put(MDC_KEY_REQUEST_ID, eventId);
metricsLogger.info(MessageCodes.RULE_AUDIT_END_INFO,
@@ -1063,7 +1064,7 @@ public class PolicyLogger {
*/
public static void metrics(String className, Object arg0) {
seTimeStamps();
- MDC.put(CLASS_NAME, className);
+ MDC.put(classNameProp, className);
String serviceName = MDC.get(MDC_SERVICE_NAME);
metricsLogger.info(MessageCodes.RULE_METRICS_INFO,
serviceName, ""+arg0);
@@ -1075,7 +1076,7 @@ public class PolicyLogger {
*/
public static void metrics(Object arg0) {
seTimeStamps();
- MDC.put(CLASS_NAME, "");
+ MDC.put(classNameProp, "");
String serviceName = MDC.get(MDC_SERVICE_NAME);
metricsLogger.info(MessageCodes.RULE_METRICS_INFO,
serviceName, ""+arg0);
@@ -1101,7 +1102,7 @@ public class PolicyLogger {
t.printStackTrace(pw);
String newStValue = sw.toString().replace ('|', '!').replace ("\n", " - ");
int curSize = arguments == null ? 0 : arguments.length;
- StringBuffer newArgument = new StringBuffer();
+ StringBuilder newArgument = new StringBuilder();
for(int i=0; i<curSize; i++) {
newArgument.append(arguments[i]);
newArgument.append(":");