summaryrefslogtreecommitdiffstats
path: root/common-logging
diff options
context:
space:
mode:
Diffstat (limited to 'common-logging')
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/eelf/ErrorCodeMap.java44
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventData.java3
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventTrackInfoHandler.java5
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/eelf/MessageCodes.java4
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/eelf/PolicyLogger.java279
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLogger.java25
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLoggerTester.java3
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/Logger4J.java23
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/PropertyUtil.java29
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/SystemOutLogger.java7
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/nsa/LoggingContextFactory.java7
-rw-r--r--common-logging/src/main/java/org/onap/policy/common/logging/nsa/impl/SharedContext.java4
12 files changed, 219 insertions, 214 deletions
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/ErrorCodeMap.java b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/ErrorCodeMap.java
index 1fce4791..6d347c9c 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/ErrorCodeMap.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/ErrorCodeMap.java
@@ -32,38 +32,38 @@ public class ErrorCodeMap {
protected static final HashMap<MessageCodes, ErrorCodeInfo> hm = new HashMap<>();
- private static String ERROR_PERMISSIONS = "POLICY-100E";
- private static String ERROR_PERMISSIONS_DESCRIPTION = "This is a Permissions Error. Please check the error message for detail information";
+ private static final String ERROR_PERMISSIONS = "POLICY-100E";
+ private static final String ERROR_PERMISSIONS_DESCRIPTION = "This is a Permissions Error. Please check the error message for detail information";
- private static String ERROR_SCHEMA_INVALID = "POLICY-400E";
- private static String ERROR_SCHEMA_INVALID_DESCRIPTION = "This is an Invalid Schema Error. Please check the error message for detail information";
+ private static final String ERROR_SCHEMA_INVALID = "POLICY-400E";
+ private static final String ERROR_SCHEMA_INVALID_DESCRIPTION = "This is an Invalid Schema Error. Please check the error message for detail information";
- private static String UPDATE_ERROR = "POLICY-502E";
- private static String UPDATE_ERROR_DESCRIPTION = "This is an updating error. Please check the error message for detail information";
+ private static final String UPDATE_ERROR = "POLICY-502E";
+ private static final String UPDATE_ERROR_DESCRIPTION = "This is an updating error. Please check the error message for detail information";
- private static String EXCEPTION_ERROR_CODE = "POLICY-503E";
- private static String EXCEPTION_ERROR_DESCRIPTION = "This is an exception error message during the process. Please check the error message for detail information";
+ private static final String EXCEPTION_ERROR_CODE = "POLICY-503E";
+ private static final String EXCEPTION_ERROR_DESCRIPTION = "This is an exception error message during the process. Please check the error message for detail information";
- private static String MISS_PROPERTY_ERROR = "POLICY-504E";
- private static String MISS_PROPERTY_ERROR_DESCRIPTION = "This is an error of missing properties. Please check the error message for detail information";
+ private static final String MISS_PROPERTY_ERROR = "POLICY-504E";
+ private static final String MISS_PROPERTY_ERROR_DESCRIPTION = "This is an error of missing properties. Please check the error message for detail information";
- private static String GENERAL_ERROR_CODE = "POLICY-515E";
- private static String GENERAL_ERROR_DESCRIPTION = "This is a general error message during the process. Please check the error message for detail information";
+ private static final String GENERAL_ERROR_CODE = "POLICY-515E";
+ private static final String GENERAL_ERROR_DESCRIPTION = "This is a general error message during the process. Please check the error message for detail information";
- private static String ERROR_SYSTEM_ERROR = "POLICY-516E";
- private static String ERROR_SYSTEM_ERROR_DESCRIPTION = "This is a System Error. Please check the error message for detail information";
+ private static final String ERROR_SYSTEM_ERROR = "POLICY-516E";
+ private static final String ERROR_SYSTEM_ERROR_DESCRIPTION = "This is a System Error. Please check the error message for detail information";
- private static String ERROR_DATA_ISSUE = "POLICY-517E";
- private static String ERROR_DATA_ISSUE_DESCRIPTION = "This is a Data Issue Error. Please check the error message for detail information";
+ private static final String ERROR_DATA_ISSUE = "POLICY-517E";
+ private static final String ERROR_DATA_ISSUE_DESCRIPTION = "This is a Data Issue Error. Please check the error message for detail information";
- private static String ERROR_PROCESS_FLOW = "POLICY-518E";
- private static String ERROR_PROCESS_FLOW_DESCRIPTION = "This is a Process Flow Error. Please check the error message for detail information";
+ private static final String ERROR_PROCESS_FLOW = "POLICY-518E";
+ private static final String ERROR_PROCESS_FLOW_DESCRIPTION = "This is a Process Flow Error. Please check the error message for detail information";
- private static String ERROR_UNKNOWN = "POLICY-519E";
- private static String ERROR_UNKNOWN_DESCRIPTION = "This is an Unknown Error. Please check the error message for detail information";
+ private static final String ERROR_UNKNOWN = "POLICY-519E";
+ private static final String ERROR_UNKNOWN_DESCRIPTION = "This is an Unknown Error. Please check the error message for detail information";
- private static String ERROR_AUDIT = "POLICY-520E";
- private static String ERROR_AUDIT_DESCRIPTION = "This is an audit Error. Please check the error message for detail information";
+ private static final String ERROR_AUDIT = "POLICY-520E";
+ private static final String ERROR_AUDIT_DESCRIPTION = "This is an audit Error. Please check the error message for detail information";
static {
hm.put(MessageCodes.EXCEPTION_ERROR, new ErrorCodeInfo(EXCEPTION_ERROR_CODE, EXCEPTION_ERROR_DESCRIPTION));
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventData.java b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventData.java
index ce31fbcb..037a144d 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventData.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventData.java
@@ -36,7 +36,8 @@ public class EventData {
//Default constructor takes no arguments.
//Is empty because instance variables are assigned
//their default values upon declaration.
- public EventData() {
+ public EventData() {
+ //See above comments for the reason this constructor is empty
}
public EventData(String requestID, Instant startTime, Instant endTime) {
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventTrackInfoHandler.java b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventTrackInfoHandler.java
index 097bc706..12f1af61 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventTrackInfoHandler.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/EventTrackInfoHandler.java
@@ -71,11 +71,11 @@ public class EventTrackInfoHandler extends TimerTask {
PolicyLogger.info(className + " duration time : " + ns);
- PolicyLogger.info(className + " PolicyLogger.EXPIRED_TIME : " + PolicyLogger.EXPIRED_TIME);
+ PolicyLogger.info(className + " PolicyLogger.EXPIRED_TIME : " + PolicyLogger.expiredTime);
// if longer than EXPIRED_TIME, remove the object
- if (ns > PolicyLogger.EXPIRED_TIME) {
+ if (ns > PolicyLogger.expiredTime) {
if (expiredEvents == null) {
expiredEvents = new ArrayList<>();
}
@@ -89,7 +89,6 @@ public class EventTrackInfoHandler extends TimerTask {
if (expiredEvents != null) {
for (String expiredKey : expiredEvents) {
eventInfo.remove(expiredKey);
- System.out.println(className + " removed expired event request ID: " + expiredKey);
PolicyLogger.info(className + " removed expired event request ID: " + expiredKey);
}
}
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/MessageCodes.java b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/MessageCodes.java
index d420fc3f..3bfce0b5 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/eelf/MessageCodes.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/eelf/MessageCodes.java
@@ -156,8 +156,8 @@ public enum MessageCodes implements EELFResolvableErrorEnum {
String id = EELFResourceManager.getIdentifier(RULE_AUDIT_EXEC_INFO);
String value = EELFResourceManager.getMessage(RULE_AUDIT_EXEC_INFO);
- System.out.println("*********************** " + id);
- System.out.println("*********************** " + value);
+ PolicyLogger.info("*********************** Rule audit id: " + id);
+ PolicyLogger.info("*********************** Rule audit value: " + value);
}
}
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 a4bd821e..b43dca45 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
@@ -75,28 +75,31 @@ public class PolicyLogger {
private static Timer timer = null;
//Default:Timer initial delay and the delay between in milliseconds before task is to be execute
- private static int TIMER_DELAY_TIME = 1000;
+ private static int timerDelayTime = 1000;
//Default:Timer scheduleAtFixedRate period - time in milliseconds between successive task executions
- private static int CHECK_INTERVAL = 30 * 1000;
+ private static int checkInterval = 30 * 1000;
//Default:longest time an event info can be stored in the concurrentHashMap for logging - in seconds
- static int EXPIRED_TIME = 60*60*1000*24; //one day
+ static int expiredTime = 60*60*1000*24; //one day
//Default:the size of the concurrentHashMap which stores the event starting time - when its size reaches this limit, the Timer get executed
- private static int CONCURRENTHASHMAP_LIMIT = 5000;
+ private static int concurrentHashMapLimit = 5000;
//Default:the size of the concurrentHashMap which stores the event starting time - when its size drops to this point, stop the Timer
- private static int STOP_CHECK_POINT = 2500;
+ private static int stopCheckPoint = 2500;
private static boolean isOverrideLogbackLevel = false;
- private static Level DEBUG_LEVEL = Level.INFO;
- private static Level AUDIT_LEVEL = Level.INFO;
- private static Level METRICS_LEVEL = Level.INFO;
- private static Level ERROR_LEVEL = Level.ERROR;
+ private static Level debugLevel = Level.INFO;
+ 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 final String DATE_FORMAT = "yyyy-MM-dd'T'HH:mm:ss.SSS+00:00";
+ private static final String COMPLETE_STATUS = "COMPLETE";
+ private static final String ERROR_CATEGORY_VALUE = "ERROR";
static{
if (hostName == null || hostAddress == null) {
@@ -110,42 +113,42 @@ public class PolicyLogger {
}
public static Level getDebugLevel() {
- return DEBUG_LEVEL;
+ return debugLevel;
}
- public synchronized static void setDebugLevel(Level level) {
- DEBUG_LEVEL = level;
+ public static synchronized void setDebugLevel(Level level) {
+ debugLevel = level;
}
public static Level getAuditLevel() {
- return AUDIT_LEVEL;
+ return auditLevel;
}
- public synchronized static void setAuditLevel(Level level) {
- AUDIT_LEVEL = level;
+ public static synchronized void setAuditLevel(Level level) {
+ auditLevel = level;
}
public static Level getMetricsLevel() {
- return METRICS_LEVEL;
+ return metricsLevel;
}
- public synchronized static void setMetricsLevel(Level level) {
- METRICS_LEVEL = level;
+ public static synchronized void setMetricsLevel(Level level) {
+ metricsLevel = level;
}
public static Level getErrorLevel() {
- return ERROR_LEVEL;
+ return errorLevel;
}
- public synchronized static void setErrorLevel(Level level) {
- ERROR_LEVEL = level;
+ public static synchronized void setErrorLevel(Level level) {
+ errorLevel = level;
}
public static String getClassname() {
return CLASS_NAME;
}
- public synchronized static void setClassname(String name) {
+ public static synchronized void setClassname(String name) {
CLASS_NAME = name;
}
@@ -157,14 +160,16 @@ public class PolicyLogger {
public static String postMDCInfoForEvent(String transId) {
MDC.clear();
- if(transId == null || transId.isEmpty()){
- transId = UUID.randomUUID().toString();
+ String transactionId = transId;
+
+ if(transactionId == null || transactionId.isEmpty()){
+ transactionId = UUID.randomUUID().toString();
}
if("DROOLS".equalsIgnoreCase(component)){
MDC.put(TARGET_ENTITY, "POLICY");
MDC.put(TARGET_SERVICE_NAME, "drools evaluate rule");
- return postMDCInfoForEvent(transId, new DroolsPDPMDCInfo());
+ return postMDCInfoForEvent(transactionId, new DroolsPDPMDCInfo());
} else {
// For Xacml
MDC.put(TARGET_ENTITY, "POLICY");
@@ -172,7 +177,7 @@ public class PolicyLogger {
}
MDC.put(MDC_REMOTE_HOST, "");
- MDC.put(MDC_KEY_REQUEST_ID, transId);
+ MDC.put(MDC_KEY_REQUEST_ID, transactionId);
MDC.put(MDC_SERVICE_NAME, "Policy.xacmlPdp");
MDC.put(MDC_SERVICE_INSTANCE_ID, "Policy.xacmlPdp.event");
try {
@@ -188,7 +193,7 @@ public class PolicyLogger {
MDC.put(MDC_INSTANCE_UUID, "");
MDC.put(MDC_ALERT_SEVERITY, "");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS+00:00");
+ SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT);
String formatedTime = sdf.format(Date.from(startTime));
MDC.put(BEGIN_TIME_STAMP, formatedTime );
@@ -200,12 +205,12 @@ public class PolicyLogger {
MDC.put(PARTNER_NAME, "N/A");
- MDC.put(STATUS_CODE, "COMPLETE");
+ MDC.put(STATUS_CODE, COMPLETE_STATUS);
MDC.put(RESPONSE_CODE, "N/A");
MDC.put(RESPONSE_DESCRIPTION, "N/A");
- return transId;
+ return transactionId;
}
@@ -240,7 +245,7 @@ public class PolicyLogger {
Instant endTime = Instant.now();
long ns = Duration.between(startTime, endTime).toMillis(); // use millisecond as default and remove unit from log
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS+00:00");
+ SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT);
String formatedTime = sdf.format(Date.from(startTime));
MDC.put(BEGIN_TIME_STAMP, formatedTime );
@@ -265,7 +270,7 @@ public class PolicyLogger {
MDC.put(MDC_INSTANCE_UUID, "");
MDC.put(MDC_ALERT_SEVERITY, "");
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS+00:00");
+ SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT);
String formatedTime = sdf.format(Date.from(startTime));
MDC.put(BEGIN_TIME_STAMP, formatedTime );
@@ -277,7 +282,7 @@ public class PolicyLogger {
MDC.put(PARTNER_NAME, "N/A");
- MDC.put(STATUS_CODE, "COMPLETE");
+ MDC.put(STATUS_CODE, COMPLETE_STATUS);
MDC.put(RESPONSE_CODE, "N/A");
MDC.put(RESPONSE_DESCRIPTION, "N/A");
@@ -311,18 +316,20 @@ public class PolicyLogger {
/**
* Resets transaction Id in MDC for the rule triggered by this event
- * @param transId
+ * @param transactionId
* @return String
*/
public static String postMDCInfoForTriggeredRule(String transId) {
+ String transactionId = transId;
+
MDC.clear();
- if(transId == null || transId.isEmpty()){
- transId = UUID.randomUUID().toString();
+ if(transactionId == null || transactionId.isEmpty()){
+ transactionId = UUID.randomUUID().toString();
}
MDC.put(MDC_REMOTE_HOST, "");
- MDC.put(MDC_KEY_REQUEST_ID, transId);
+ MDC.put(MDC_KEY_REQUEST_ID, transactionId);
MDC.put(MDC_SERVICE_NAME, "Policy.droolsPdp");
MDC.put(MDC_SERVICE_INSTANCE_ID, "");
try {
@@ -333,9 +340,9 @@ public class PolicyLogger {
}
MDC.put(MDC_INSTANCE_UUID, "");
MDC.put(MDC_ALERT_SEVERITY, "");
- MDC.put(STATUS_CODE, "COMPLETE");
+ MDC.put(STATUS_CODE, COMPLETE_STATUS);
- return transId;
+ return transactionId;
}
@@ -515,7 +522,7 @@ public class PolicyLogger {
*/
public static void error(String arg0) {
MDC.put(CLASS_NAME, "");
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR) != null){
MDC.put(ERROR_CODE, ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR).getErrorCode());
@@ -531,7 +538,7 @@ public class PolicyLogger {
*/
public static void error(Object arg0) {
MDC.put(CLASS_NAME, "");
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR) != null){
MDC.put(ERROR_CODE, ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR).getErrorCode());
@@ -550,7 +557,7 @@ public class PolicyLogger {
public static void error(MessageCodes msg, Throwable arg0,
String... arguments) {
MDC.put(CLASS_NAME, "");
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(msg) != null){
MDC.put(ERROR_CODE, ErrorCodeMap.hm.get(msg).getErrorCode());
@@ -571,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(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(msg) != null){
MDC.put(ERROR_CODE, ErrorCodeMap.hm.get(msg).getErrorCode());
@@ -589,7 +596,7 @@ public class PolicyLogger {
*/
public static void error(MessageCodes msg, String... arguments) {
MDC.put(CLASS_NAME, "");
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(msg) != null){
MDC.put(ERROR_CODE, ErrorCodeMap.hm.get(msg).getErrorCode());
@@ -644,7 +651,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void audit(String className, Object arg0) {
- MDC.put(STATUS_CODE, "COMPLETE");
+ MDC.put(STATUS_CODE, COMPLETE_STATUS);
MDC.put(CLASS_NAME, className);
auditLogger.info("" + arg0);
}
@@ -654,7 +661,7 @@ public class PolicyLogger {
* @param arg0
*/
public static void audit(Object arg0) {
- MDC.put(STATUS_CODE, "COMPLETE");
+ MDC.put(STATUS_CODE, COMPLETE_STATUS);
MDC.put(CLASS_NAME, "");
auditLogger.info("" + arg0);
}
@@ -758,7 +765,7 @@ public class PolicyLogger {
*/
public static void recordAuditEventStart(String eventId) {
- MDC.put(STATUS_CODE, "COMPLETE");
+ MDC.put(STATUS_CODE, COMPLETE_STATUS);
postMDCInfoForEvent(eventId);
if(eventTracker == null){
@@ -769,14 +776,14 @@ public class PolicyLogger {
event.setStartTime(Instant.now());
eventTracker.storeEventData(event);
MDC.put(MDC_KEY_REQUEST_ID, eventId);
- debugLogger.info("CONCURRENTHASHMAP_LIMIT : " + CONCURRENTHASHMAP_LIMIT);
+ debugLogger.info("CONCURRENTHASHMAP_LIMIT : " + concurrentHashMapLimit);
//--- Tracking the size of the concurrentHashMap, if it is above limit, keep EventTrack Timer running
int size = eventTracker.getEventInfo().size();
debugLogger.info("EventInfo concurrentHashMap Size : " + size + " on " + new Date());
debugLogger.info("isEventTrackerRunning : " + isEventTrackerRunning);
- if( size >= CONCURRENTHASHMAP_LIMIT){
+ if( size >= concurrentHashMapLimit){
if(!isEventTrackerRunning){
@@ -785,7 +792,7 @@ public class PolicyLogger {
isEventTrackerRunning = true;
}
- }else if( size <= STOP_CHECK_POINT && isEventTrackerRunning){
+ }else if( size <= stopCheckPoint && isEventTrackerRunning){
stopCleanUp();
}
@@ -897,7 +904,7 @@ public class PolicyLogger {
if(endTime == null){
endTime = Instant.now();
}
- MDC.put(STATUS_CODE, "COMPLETE");
+ MDC.put(STATUS_CODE, COMPLETE_STATUS);
recordAuditEventStartToEnd(eventId, rule, event.getStartTime(), endTime, policyVersion);
}
}
@@ -951,7 +958,7 @@ public class PolicyLogger {
MDC.put(MDC_KEY_REQUEST_ID, eventId);
}
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS+00:00");
+ SimpleDateFormat sdf = new SimpleDateFormat(DATE_FORMAT);
String formatedTime = sdf.format(Date.from(startTime));
MDC.put(BEGIN_TIME_STAMP, formatedTime );
@@ -1111,7 +1118,7 @@ public class PolicyLogger {
if(!isEventTrackerRunning) {
ttrcker = new EventTrackInfoHandler();
timer = new Timer(true);
- timer.scheduleAtFixedRate(ttrcker, TIMER_DELAY_TIME, CHECK_INTERVAL);
+ timer.scheduleAtFixedRate(ttrcker, timerDelayTime, checkInterval);
debugLogger.info("EventTrackInfoHandler begins! : " + new Date());
}else{
debugLogger.info("Timer is still running : " + new Date());
@@ -1150,22 +1157,22 @@ public class PolicyLogger {
loggerProperties = new Properties();
}
- LoggerType logger_type = LoggerType.EELF;
+ LoggerType loggerType = LoggerType.EELF;
// fetch and verify definitions of some properties
try{
- int timerDelayTime = Integer.parseInt(loggerProperties.getProperty("timer.delay.time", Integer.toString(1000)));
- int checkInterval = Integer.parseInt(loggerProperties.getProperty("check.interval", Integer.toString(30000)));
- int expiredDate = Integer.parseInt(loggerProperties.getProperty("event.expired.time", Integer.toString(86400)));
- int concurrentHashMapLimit = Integer.parseInt(loggerProperties.getProperty("concurrentHashMap.limit", Integer.toString(5000)));
- int stopCheckPoint = Integer.parseInt(loggerProperties.getProperty("stop.check.point", Integer.toString(2500)));
- String loggerType = loggerProperties.getProperty("logger.type",logger_type.toString());
+ int timerDelayTimeProp = Integer.parseInt(loggerProperties.getProperty("timer.delay.time", Integer.toString(1000)));
+ int checkIntervalProp = Integer.parseInt(loggerProperties.getProperty("check.interval", Integer.toString(30000)));
+ int expiredDateProp = Integer.parseInt(loggerProperties.getProperty("event.expired.time", Integer.toString(86400)));
+ int concurrentHashMapLimitProp = Integer.parseInt(loggerProperties.getProperty("concurrentHashMap.limit", Integer.toString(5000)));
+ int stopCheckPointProp = Integer.parseInt(loggerProperties.getProperty("stop.check.point", Integer.toString(2500)));
+ String loggerTypeProp = loggerProperties.getProperty("logger.type",loggerType.toString());
- String debugLevel = loggerProperties.getProperty("debugLogger.level","INFO");
- String metricsLevel = loggerProperties.getProperty("metricsLogger.level","ON");
- String auditLevel = loggerProperties.getProperty("error.level","ON");
- String errorLevel = loggerProperties.getProperty("audit.level","ON");
+ String debugLevelProp = loggerProperties.getProperty("debugLogger.level","INFO");
+ String metricsLevelProp = loggerProperties.getProperty("metricsLogger.level","ON");
+ String auditLevelProp = loggerProperties.getProperty("error.level","ON");
+ String errorLevelProp = loggerProperties.getProperty("audit.level","ON");
component = loggerProperties.getProperty("policy.component","DROOLS");
String overrideLogbackLevel = loggerProperties.getProperty("override.logback.level.setup");
@@ -1178,169 +1185,169 @@ public class PolicyLogger {
}
- if (debugLevel != null && !debugLevel.isEmpty()){
+ if (debugLevelProp != null && !debugLevelProp.isEmpty()){
- PolicyLogger.setDebugLevel(Level.valueOf(debugLevel));
+ PolicyLogger.setDebugLevel(Level.valueOf(debugLevelProp));
}
//Only check if it is to turn off or not
- if (errorLevel != null && errorLevel.equalsIgnoreCase(Level.OFF.toString())){
+ if (errorLevelProp != null && errorLevelProp.equalsIgnoreCase(Level.OFF.toString())){
- PolicyLogger.setErrorLevel(Level.valueOf(errorLevel));
+ PolicyLogger.setErrorLevel(Level.valueOf(errorLevelProp));
}
//Only check if it is to turn off or not
- if (metricsLevel != null && metricsLevel.equalsIgnoreCase(Level.OFF.toString())){
+ if (metricsLevelProp != null && metricsLevelProp.equalsIgnoreCase(Level.OFF.toString())){
- PolicyLogger.setMetricsLevel(Level.valueOf(metricsLevel));
+ PolicyLogger.setMetricsLevel(Level.valueOf(metricsLevelProp));
}
//Only check if it is to turn off or not
- if (auditLevel != null && auditLevel.equalsIgnoreCase(Level.OFF.toString())){
+ if (auditLevelProp != null && auditLevelProp.equalsIgnoreCase(Level.OFF.toString())){
- PolicyLogger.setAuditLevel(Level.valueOf(auditLevel));
+ PolicyLogger.setAuditLevel(Level.valueOf(auditLevelProp));
}
if(isOverrideLogbackLevel){
- debugLogger.setLevel(DEBUG_LEVEL);
- metricsLogger.setLevel(METRICS_LEVEL);
- auditLogger.setLevel(AUDIT_LEVEL);
- errorLogger.setLevel(ERROR_LEVEL);
+ debugLogger.setLevel(debugLevel);
+ metricsLogger.setLevel(metricsLevel);
+ auditLogger.setLevel(auditLevel);
+ errorLogger.setLevel(errorLevel);
}
isEventTrackerRunning = false;
- debugLogger.info("timerDelayTime value: " + timerDelayTime);
+ debugLogger.info("timerDelayTime value: " + timerDelayTimeProp);
- debugLogger.info("checkInterval value: " + checkInterval);
+ debugLogger.info("checkInterval value: " + checkIntervalProp);
- debugLogger.info("expiredDate value: " + expiredDate);
+ debugLogger.info("expiredDate value: " + expiredDateProp);
- debugLogger.info("concurrentHashMapLimit value: " + concurrentHashMapLimit);
+ debugLogger.info("concurrentHashMapLimit value: " + concurrentHashMapLimitProp);
- debugLogger.info("loggerType value: " + loggerType);
+ debugLogger.info("loggerType value: " + loggerTypeProp);
- debugLogger.info("debugLogger level: " + debugLevel);
+ debugLogger.info("debugLogger level: " + debugLevelProp);
debugLogger.info("component: " + component);
- if (timerDelayTime > 0){
+ if (timerDelayTimeProp > 0){
- TIMER_DELAY_TIME = timerDelayTime;
+ timerDelayTime = timerDelayTimeProp;
}else {
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
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());
}
- errorLogger.error("failed to get the timer.delay.time, so use its default value: " + TIMER_DELAY_TIME);
+ errorLogger.error("failed to get the timer.delay.time, so use its default value: " + timerDelayTime);
}
- if (checkInterval > 0){
+ if (checkIntervalProp > 0){
- CHECK_INTERVAL = checkInterval;
+ checkInterval = checkIntervalProp;
}else {
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
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());
}
- errorLogger.error("failed to get the check.interval, so use its default value: " + CHECK_INTERVAL);
+ errorLogger.error("failed to get the check.interval, so use its default value: " + checkInterval);
}
- if (expiredDate > 0){
+ if (expiredDateProp > 0){
- EXPIRED_TIME = expiredDate;
+ expiredTime = expiredDateProp;
}else {
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
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());
}
- errorLogger.error("failed to get the event.expired.time, so use its default value: " + EXPIRED_TIME);
+ errorLogger.error("failed to get the event.expired.time, so use its default value: " + expiredTime);
}
- if (concurrentHashMapLimit > 0){
+ if (concurrentHashMapLimitProp > 0){
- CONCURRENTHASHMAP_LIMIT = concurrentHashMapLimit;
+ concurrentHashMapLimit = concurrentHashMapLimitProp;
}else {
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
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());
}
- errorLogger.error("failed to get the concurrentHashMap.limit, so use its default value: " + CONCURRENTHASHMAP_LIMIT);
+ errorLogger.error("failed to get the concurrentHashMap.limit, so use its default value: " + concurrentHashMapLimit);
}
- if (stopCheckPoint > 0){
+ if (stopCheckPointProp > 0){
- STOP_CHECK_POINT = stopCheckPoint;
+ stopCheckPoint = stopCheckPointProp;
}else {
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
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());
}
- errorLogger.error("failed to get the stop.check.point, so use its default value: " + STOP_CHECK_POINT);
+ errorLogger.error("failed to get the stop.check.point, so use its default value: " + stopCheckPoint);
}
- if (loggerType != null){
+ if (loggerTypeProp != null){
- if ("EELF".equalsIgnoreCase(loggerType)){
+ if ("EELF".equalsIgnoreCase(loggerTypeProp)){
- logger_type = LoggerType.EELF;
+ loggerType = LoggerType.EELF;
- }else if ("LOG4J".equalsIgnoreCase(loggerType)){
+ }else if ("LOG4J".equalsIgnoreCase(loggerTypeProp)){
- logger_type = LoggerType.LOG4J;
+ loggerType = LoggerType.LOG4J;
- }else if ("SYSTEMOUT".equalsIgnoreCase(loggerType)){
+ }else if ("SYSTEMOUT".equalsIgnoreCase(loggerTypeProp)){
- logger_type = LoggerType.SYSTEMOUT;
+ loggerType = LoggerType.SYSTEMOUT;
}
}
- if (debugLevel != null && !debugLevel.isEmpty()){
+ if (debugLevelProp != null && !debugLevelProp.isEmpty()){
- DEBUG_LEVEL = Level.valueOf(debugLevel);
+ debugLevel = Level.valueOf(debugLevelProp);
}
//Only check if it is to turn off or not
- if (errorLevel != null && errorLevel.equalsIgnoreCase(Level.OFF.toString())){
+ if (errorLevelProp != null && errorLevelProp.equalsIgnoreCase(Level.OFF.toString())){
- ERROR_LEVEL = Level.valueOf(errorLevel);
+ errorLevel = Level.valueOf(errorLevelProp);
}
//Only check if it is to turn off or not
- if (metricsLevel != null && metricsLevel.equalsIgnoreCase(Level.OFF.toString())){
+ if (metricsLevelProp != null && metricsLevelProp.equalsIgnoreCase(Level.OFF.toString())){
- METRICS_LEVEL = Level.valueOf(metricsLevel);
+ metricsLevel = Level.valueOf(metricsLevelProp);
}
//Only check if it is to turn off or not
- if (auditLevel != null && auditLevel.equalsIgnoreCase(Level.OFF.toString())){
+ if (auditLevelProp != null && auditLevelProp.equalsIgnoreCase(Level.OFF.toString())){
- AUDIT_LEVEL = Level.valueOf(auditLevel);
+ auditLevel = Level.valueOf(auditLevelProp);
}
}catch(Exception e){
- MDC.put(ERROR_CATEGORY, "ERROR");
+ MDC.put(ERROR_CATEGORY, ERROR_CATEGORY_VALUE);
if(ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR) != null){
MDC.put(ERROR_CODE, ErrorCodeMap.hm.get(MessageCodes.GENERAL_ERROR).getErrorCode());
@@ -1350,18 +1357,18 @@ public class PolicyLogger {
errorLogger.error("failed to get the policyLogger.properties, so use their default values",e);
}
- return logger_type;
+ return loggerType;
}
/**
* Sets Debug Level
*/
- public static void setDebugLevel(String debugLevel){
+ public static void setDebugLevel(String newDebugLevel){
if(isOverrideLogbackLevel){
- PolicyLogger.DEBUG_LEVEL = Level.valueOf(debugLevel);
- debugLogger.setLevel(DEBUG_LEVEL);
+ PolicyLogger.debugLevel = Level.valueOf(newDebugLevel);
+ debugLogger.setLevel(debugLevel);
}
}
@@ -1369,16 +1376,16 @@ public class PolicyLogger {
/**
* Sets Error OFF or ON
*/
- public static void setErrorLevel(String errorLevel){
+ public static void setErrorLevel(String newErrorLevel){
if(isOverrideLogbackLevel){
- if("OFF".equalsIgnoreCase(errorLevel)){
- PolicyLogger.ERROR_LEVEL = Level.OFF;
- errorLogger.setLevel(ERROR_LEVEL);
+ if("OFF".equalsIgnoreCase(newErrorLevel)){
+ PolicyLogger.errorLevel = Level.OFF;
+ errorLogger.setLevel(errorLevel);
}else{
//--- set default value
errorLogger.setLevel(Level.ERROR);
- PolicyLogger.ERROR_LEVEL = Level.ERROR;
+ PolicyLogger.errorLevel = Level.ERROR;
}
}
}
@@ -1386,16 +1393,16 @@ public class PolicyLogger {
/**
* Sets Metrics OFF or ON
*/
- public static void setMetricsLevel(String metricsLevel){
+ public static void setMetricsLevel(String newMetricsLevel){
if(isOverrideLogbackLevel){
- if("OFF".equalsIgnoreCase(metricsLevel)){
- PolicyLogger.METRICS_LEVEL = Level.OFF;
- metricsLogger.setLevel(METRICS_LEVEL);
+ if("OFF".equalsIgnoreCase(newMetricsLevel)){
+ PolicyLogger.metricsLevel = Level.OFF;
+ metricsLogger.setLevel(metricsLevel);
}else {
//--- set default value
metricsLogger.setLevel(Level.INFO);
- PolicyLogger.METRICS_LEVEL = Level.INFO;
+ PolicyLogger.metricsLevel = Level.INFO;
}
}
@@ -1404,16 +1411,16 @@ public class PolicyLogger {
/**
* Sets Audit OFF or ON
*/
- public static void setAuditLevel(String auditLevel){
+ public static void setAuditLevel(String newAuditLevel){
if(isOverrideLogbackLevel){
- if("OFF".equalsIgnoreCase(auditLevel)){
- PolicyLogger.AUDIT_LEVEL = Level.OFF;
- auditLogger.setLevel(AUDIT_LEVEL);
+ if("OFF".equalsIgnoreCase(newAuditLevel)){
+ PolicyLogger.auditLevel = Level.OFF;
+ auditLogger.setLevel(auditLevel);
}else {
//--- set default value
auditLogger.setLevel(Level.INFO);
- PolicyLogger.AUDIT_LEVEL = Level.INFO;
+ PolicyLogger.auditLevel = Level.INFO;
}
}
}
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLogger.java b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLogger.java
index 2cf591cb..9723755e 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLogger.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLogger.java
@@ -38,6 +38,7 @@ import org.onap.policy.common.logging.flexlogger.PropertyUtil.Listener;
*/
public class FlexLogger extends SecurityManager{
+ private static final String GET_LOGGER_PREFIX = "FlexLogger:getLogger : loggerType = ";
private static LoggerType loggerType = LoggerType.EELF;
private static ConcurrentHashMap<String, Logger4J> logger4JMap = new ConcurrentHashMap<>();
private static ConcurrentHashMap<String, EelfLogger> eelfLoggerMap = new ConcurrentHashMap<>();
@@ -51,9 +52,9 @@ public class FlexLogger extends SecurityManager{
* Returns an instance of Logger
* @param clazz
*/
- static public Logger getLogger(Class<?> clazz) {
+ public static Logger getLogger(Class<?> clazz) {
Logger logger = null;
- System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+ System.out.println(GET_LOGGER_PREFIX + loggerType);
switch (loggerType) {
case EELF:
@@ -75,9 +76,9 @@ public class FlexLogger extends SecurityManager{
* Returns an instance of Logger
* @param s
*/
- static public Logger getLogger(String s) {
+ public static Logger getLogger(String s) {
Logger logger = null;
- System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+ System.out.println(GET_LOGGER_PREFIX + loggerType);
switch (loggerType) {
case EELF:
@@ -100,9 +101,9 @@ public class FlexLogger extends SecurityManager{
* @param clazz
* @param isNewTransaction
*/
- static public Logger getLogger(Class<?> clazz, boolean isNewTransaction) {
+ public static Logger getLogger(Class<?> clazz, boolean isNewTransaction) {
Logger logger = null;
- System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+ System.out.println(GET_LOGGER_PREFIX + loggerType);
switch (loggerType) {
case EELF:
@@ -125,9 +126,9 @@ public class FlexLogger extends SecurityManager{
* @param s
* @param isNewTransaction
*/
- static public Logger getLogger(String s, boolean isNewTransaction) {
+ public static Logger getLogger(String s, boolean isNewTransaction) {
Logger logger = null;
- System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+ System.out.println(GET_LOGGER_PREFIX + loggerType);
switch (loggerType) {
case EELF:
@@ -251,7 +252,7 @@ public class FlexLogger extends SecurityManager{
System.out.println("FlexLogger:overrideLogbackLevel => " + overrideLogbackLevel);
loggerTypeString = properties.getProperty("logger.type");
if (loggerTypeString != null){
- if (loggerTypeString.equalsIgnoreCase("EELF")){
+ if ("EELF".equalsIgnoreCase(loggerTypeString)){
loggerType = LoggerType.EELF;
if ("TRUE".equalsIgnoreCase(overrideLogbackLevel)) {
System.out.println("FlexLogger: start listener.");
@@ -259,9 +260,9 @@ public class FlexLogger extends SecurityManager{
("config/policyLogger.properties",
new PropertiesCallBack("FlexLogger-CallBack"));
}
- }else if (loggerTypeString.equalsIgnoreCase("LOG4J")){
+ }else if ("LOG4J".equalsIgnoreCase(loggerTypeString)){
loggerType = LoggerType.LOG4J;
- }else if (loggerTypeString.equalsIgnoreCase("SYSTEMOUT")){
+ }else if ("SYSTEMOUT".equalsIgnoreCase(loggerTypeString)){
loggerType = LoggerType.SYSTEMOUT;
}
@@ -281,7 +282,7 @@ public class FlexLogger extends SecurityManager{
/**
* PropertiesCallBack is listening any updates on the policyLogger.properties
*/
- static public class PropertiesCallBack implements Listener {
+ public static class PropertiesCallBack implements Listener {
String name;
public PropertiesCallBack(String name) {
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLoggerTester.java b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLoggerTester.java
index ff33c299..0fa65c0c 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLoggerTester.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/FlexLoggerTester.java
@@ -42,7 +42,8 @@ public class FlexLoggerTester {
else
logger.info("this is from logger.info call");
- if(logger.isMetricsEnabled()) logger.metrics("this is from logger.metrics call");
+ if(logger.isMetricsEnabled())
+ logger.metrics("this is from logger.metrics call");
logger.error("this is from logger.error call");
if(logger.isAuditEnabled())
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/Logger4J.java b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/Logger4J.java
index 9fcd47af..746012d1 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/Logger4J.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/Logger4J.java
@@ -182,12 +182,8 @@ public class Logger4J implements org.onap.policy.common.logging.flexlogger.Logge
* @return boolean
*/
@Override
- public boolean isAuditEnabled(){
- if(PolicyLogger.getAuditLevel() != null && PolicyLogger.getAuditLevel().toString().equals(Level.OFF.toString())){
- return false;
- }else {
- return true;
- }
+ public boolean isAuditEnabled(){
+ return !(PolicyLogger.getAuditLevel() != null && PolicyLogger.getAuditLevel().toString().equals(Level.OFF.toString()));
}
/**
@@ -196,11 +192,7 @@ public class Logger4J implements org.onap.policy.common.logging.flexlogger.Logge
*/
@Override
public boolean isMetricsEnabled(){
- if(PolicyLogger.getMetricsLevel() != null && PolicyLogger.getMetricsLevel().toString().equals(Level.OFF.toString())){
- return false;
- }else {
- return true;
- }
+ return !(PolicyLogger.getMetricsLevel() != null && PolicyLogger.getMetricsLevel().toString().equals(Level.OFF.toString()));
}
/**
@@ -343,12 +335,13 @@ public class Logger4J implements org.onap.policy.common.logging.flexlogger.Logge
* @param transId
*/
@Override
- public String postMDCInfoForEvent(String transId) {
- if(transId == null || transId.isEmpty()){
- transId = UUID.randomUUID().toString();
+ public String postMDCInfoForEvent(String transId) {
+ String transactionId = transId;
+ if(transactionId == null || transactionId.isEmpty()){
+ transactionId = UUID.randomUUID().toString();
}
- return transId;
+ return transactionId;
}
/**
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/PropertyUtil.java b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/PropertyUtil.java
index d2a98239..1bc57f01 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/PropertyUtil.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/PropertyUtil.java
@@ -37,6 +37,14 @@ import java.util.TimerTask;
*/
public class PropertyUtil
{
+
+ // timer thread used for polling for property file changes
+ private static Timer timer = null;
+
+ // this table maps canonical file into a 'ListenerRegistration' instance
+ private static HashMap<File, ListenerRegistration> registrations =
+ new HashMap<>();
+
/**
* Read in a properties file
* @param file the properties file
@@ -45,7 +53,7 @@ public class PropertyUtil
* does not exist or can't be opened, and 'IOException' if there is
* a problem loading the properties file.
*/
- static public Properties getProperties(File file) throws IOException
+ public static Properties getProperties(File file) throws IOException
{
// create an InputStream (may throw a FileNotFoundException)
FileInputStream fis = new FileInputStream(file);
@@ -73,16 +81,13 @@ public class PropertyUtil
* does not exist or can't be opened, and 'IOException' if there is
* a problem loading the properties file.
*/
- static public Properties getProperties(String fileName) throws IOException
+ public static Properties getProperties(String fileName) throws IOException
{
return getProperties(new File(fileName));
}
/* ============================================================ */
- // timer thread used for polling for property file changes
- private static Timer timer = null;
-
/**
* This is the callback interface, used for sending notifications of
* changes in the properties file.
@@ -99,10 +104,6 @@ public class PropertyUtil
void propertiesChanged(Properties properties, Set<String> changedKeys);
}
- // this table maps canonical file into a 'ListenerRegistration' instance
- static private HashMap<File, ListenerRegistration> registrations =
- new HashMap<>();
-
/**
* This is an internal class - one instance of this exists for each
* property file that is being monitored. Note that multiple listeners
@@ -306,7 +307,7 @@ public class PropertyUtil
* does not exist or can't be opened, and 'IOException' if there is
* a problem loading the properties file.
*/
- static public Properties getProperties(File file, Listener listener)
+ public static Properties getProperties(File file, Listener listener)
throws IOException
{
if (listener == null)
@@ -350,7 +351,7 @@ public class PropertyUtil
* does not exist or can't be opened, and 'IOException' if there is
* a problem loading the properties file.
*/
- static public Properties getProperties(String fileName, Listener listener)
+ public static Properties getProperties(String fileName, Listener listener)
throws IOException
{
return getProperties(new File(fileName), listener);
@@ -362,7 +363,7 @@ public class PropertyUtil
* @param notify if not null, this is a callback interface that was used for
* notifications of changes
*/
- static public void stopListening(File file, Listener listener)
+ public static void stopListening(File file, Listener listener)
{
if (listener != null)
{
@@ -380,7 +381,7 @@ public class PropertyUtil
* @param notify if not null, this is a callback interface that was used for
* notifications of changes
*/
- static public void stopListening(String fileName, Listener listener)
+ public static void stopListening(String fileName, Listener listener)
{
stopListening(new File(fileName), listener);
}
@@ -388,7 +389,7 @@ public class PropertyUtil
/* ============================================================ */
// TEMPORARY - used to test callback interface
- static public class Test implements Listener
+ public static class Test implements Listener
{
String name;
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/SystemOutLogger.java b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/SystemOutLogger.java
index aeb26017..295e259a 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/SystemOutLogger.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/flexlogger/SystemOutLogger.java
@@ -380,11 +380,12 @@ public class SystemOutLogger implements Logger, Serializable {
@Override
public String postMDCInfoForEvent(String transId) {
- if(transId == null || transId.isEmpty()){
- transId = UUID.randomUUID().toString();
+ String transactionId = transId;
+ if(transactionId == null || transactionId.isEmpty()){
+ transactionId = UUID.randomUUID().toString();
}
- return transId;
+ return transactionId;
}
/**
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/nsa/LoggingContextFactory.java b/common-logging/src/main/java/org/onap/policy/common/logging/nsa/LoggingContextFactory.java
index 78fffefe..b2ad76ca 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/nsa/LoggingContextFactory.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/nsa/LoggingContextFactory.java
@@ -32,6 +32,10 @@ public class LoggingContextFactory
{
public static class Builder
{
+
+ private LoggingContext fBase = null;
+ private boolean fShared = false;
+
public Builder withBaseContext ( LoggingContext lc )
{
fBase = lc;
@@ -48,8 +52,5 @@ public class LoggingContextFactory
{
return fShared ? new SharedContext ( fBase ) : new Slf4jLoggingContext ( fBase );
}
-
- private LoggingContext fBase = null;
- private boolean fShared = false;
}
}
diff --git a/common-logging/src/main/java/org/onap/policy/common/logging/nsa/impl/SharedContext.java b/common-logging/src/main/java/org/onap/policy/common/logging/nsa/impl/SharedContext.java
index 7f4a1096..97f61699 100644
--- a/common-logging/src/main/java/org/onap/policy/common/logging/nsa/impl/SharedContext.java
+++ b/common-logging/src/main/java/org/onap/policy/common/logging/nsa/impl/SharedContext.java
@@ -32,6 +32,8 @@ import org.onap.policy.common.logging.nsa.SharedLoggingContext;
*/
public class SharedContext extends Slf4jLoggingContext implements SharedLoggingContext
{
+ private final HashMap<String,String> fMap;
+
public SharedContext ( LoggingContext base )
{
super ( base );
@@ -53,6 +55,4 @@ public class SharedContext extends Slf4jLoggingContext implements SharedLoggingC
lc.put ( e.getKey(), e.getValue() );
}
}
-
- private final HashMap<String,String> fMap;
}