下面列出了org.apache.log4j.AppenderSkeleton#org.apache.log4j.Priority 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。
@Override
@SuppressFBWarnings(value = "SF_SWITCH_NO_DEFAULT",justification = "Intentional")
public void trace(TraceLevel level, String traceString){
Priority prio = Level.INFO;
switch(level){
case TRACE:
prio = Level.TRACE;
break;
case DEBUG:
prio = Level.DEBUG;
break;
case WARN:
prio = Level.WARN;
break;
case ERROR:
prio = Level.ERROR;
break;
}
if (TRACE_LOGGER.isTraceEnabled()) {
TRACE_LOGGER.log(prio,traceString);
}
}
/**
* Get the appropriate control characters to change
* the colour for the specified logging level.
*/
private String getColour(org.apache.log4j.Level level) {
switch (level.toInt()) {
case Priority.FATAL_INT:
return FATAL_COLOUR;
case Priority.ERROR_INT:
return ERROR_COLOUR;
case Priority.WARN_INT:
return WARN_COLOUR;
case Priority.INFO_INT:
return INFO_COLOUR;
case Priority.DEBUG_INT:
return DEBUG_COLOUR;
default:
return TRACE_COLOUR;
}
}
private int mapLevel(Level level) {
switch (level.toInt()) {
case Priority.DEBUG_INT:
case Priority.INFO_INT:
return IStatus.INFO;
case Priority.WARN_INT:
return IStatus.WARNING;
case Priority.ERROR_INT:
case Priority.FATAL_INT:
return IStatus.ERROR;
default:
return IStatus.INFO;
}
}
private int mapLevel(Level level) {
switch (level.toInt()) {
case Priority.DEBUG_INT:
case Priority.INFO_INT:
return IStatus.INFO;
case Priority.WARN_INT:
return IStatus.WARNING;
case Priority.ERROR_INT:
case Priority.FATAL_INT:
return IStatus.ERROR;
default:
return IStatus.INFO;
}
}
/**
* Tests LoggingEvent.getLocationInfo() when no FQCN is specified.
* See bug 41186.
*/
public void testLocationInfoNoFQCN() {
Category root = Logger.getRootLogger();
Priority level = Level.INFO;
LoggingEvent event =
new LoggingEvent(
null, root, 0L, level, "Hello, world.", null);
LocationInfo info = event.getLocationInformation();
//
// log4j 1.2 returns an object, its layout doesn't check for nulls.
// log4j 1.3 returns a null.
//
assertNotNull(info);
if (info != null) {
assertEquals("?", info.getLineNumber());
assertEquals("?", info.getClassName());
assertEquals("?", info.getFileName());
assertEquals("?", info.getMethodName());
}
}
public
void run() {
while(true) {
synchronized(this) {
try {
this.wait();
} catch(Exception e) {
}
}
for(int i = 0; i < burst; i++) {
LoggingEvent event = new LoggingEvent("x", cat, Priority.DEBUG,
"Message "+counter, null);
event.getThreadName();
if(counter % 50 == 0) {
//event.throwable = new Exception("hello "+counter);
}
counter++;
view.add(event);
}
}
}
@Override
public void l7dlog(Priority priority, String key, Object[] params, Throwable t) {
if (isForcedToLog(priority)) {
// from super.l7dlog:
String pattern = getResourceBundleString(key);
String msg;
if (pattern == null)
msg = key;
else
msg = java.text.MessageFormat.format(pattern, params);
final Appender forcedAppender = getForcedAppender();
// force the logging and modify the log message (the latter might return the original message)
if (forcedAppender != null) {
// only call the forced appender
forcedAppender.doAppend(new LoggingEvent(FQCN, this, priority, modifyLogMessage(msg), t));
} else {
// go via the normal appenders
forcedLog(FQCN, priority, modifyLogMessage(msg), t);
}
} else {
super.l7dlog(priority, key, params, t);
}
}
/**
* Logger worker method - does the actual checks whether the given message should be logged at the given priority - taking into account this logger's loglevel plus
* the threadLocalLogLevel.
*
* @param priority
* the priority at which the given message should be logged
* @param message
* the message which should be logged (or not, depending on levels)
*/
private final void threadLocalAwareLog(String fQCN, Priority priority, Object message, Throwable t) {
if (isForcedToLog(priority)) {
final Appender forcedAppender = getForcedAppender();
// force the logging and modify the log message (the latter might return the original message)
if (forcedAppender != null) {
// only call the forced appender
forcedAppender.doAppend(new LoggingEvent(fQCN, this, priority, modifyLogMessage(message), t));
} else {
// go via the normal appenders
forcedLog(fQCN, priority, modifyLogMessage(message), t);
}
} else {
// else not forced to log - use default behaviour
super.log(fQCN, priority, message, t);
}
}
private void printJexlNode(JexlNode queryTree, String message, Priority priority) {
if (log.isEnabledFor(priority)) {
log.log(priority, message);
for (String line : PrintingVisitor.formattedQueryStringList(queryTree)) {
log.log(priority, line);
}
}
}
@Test
public void testThrowableSuccess() throws Exception
{
CassandraAppender appender = new CassandraAppender();
LoggingEvent event = new LoggingEvent(BasicTest.class.getName(),
Category.getInstance(BasicTest.class),
Priority.WARN,
"test 12",
new Exception("boom"));
appender.doAppend(event);
}
/**
* Convert <code>val</code> a String parameter to an object of a
* given type.
* @param val The value to convert.
* @param type The type of the value to convert to.
* @return The result of the conversion.
*/
protected Object convertArg(String val, Class<?> type) {
if (val == null) {
return null;
}
String v = val.trim();
if (String.class.isAssignableFrom(type)) {
return val;
} else if (Integer.TYPE.isAssignableFrom(type)) {
return Integer.parseInt(v);
} else if (Long.TYPE.isAssignableFrom(type)) {
return Long.parseLong(v);
} else if (Boolean.TYPE.isAssignableFrom(type)) {
if ("true".equalsIgnoreCase(v)) {
return Boolean.TRUE;
} else if ("false".equalsIgnoreCase(v)) {
return Boolean.FALSE;
}
} else if (Priority.class.isAssignableFrom(type)) {
return org.apache.log4j.helpers.OptionConverter.toLevel(v, Level.DEBUG);
} else if (ErrorHandler.class.isAssignableFrom(type)) {
return OptionConverter.instantiateByClassName(v,
ErrorHandler.class, null);
}
return null;
}
/**
* test TaskLogAppender
*/
@SuppressWarnings("deprecation")
@Test (timeout=5000)
public void testTaskLogAppender(){
TaskLogAppender appender= new TaskLogAppender();
System.setProperty(TaskLogAppender.TASKID_PROPERTY,"attempt_01_02_m03_04_001");
System.setProperty(TaskLogAppender.LOGSIZE_PROPERTY, "1003");
appender.activateOptions();
assertEquals(appender.getTaskId(), "attempt_01_02_m03_04_001");
assertEquals(appender.getTotalLogFileSize(),1000);
assertEquals(appender.getIsCleanup(),false);
// test writer
Writer writer= new StringWriter();
appender.setWriter(writer);
Layout layout = new PatternLayout("%-5p [%t]: %m%n");
appender.setLayout(layout);
Category logger= Logger.getLogger(getClass().getName());
LoggingEvent event = new LoggingEvent("fqnOfCategoryClass", logger, Priority.INFO, "message", new Throwable());
appender.append(event);
appender.flush() ;
appender.close();
assertTrue(writer.toString().length()>0);
// test cleanup should not changed
appender= new TaskLogAppender();
appender.setIsCleanup(true);
appender.activateOptions();
assertEquals(appender.getIsCleanup(),true);
}
/**
* test TaskLogAppender
*/
@SuppressWarnings("deprecation")
@Test (timeout=5000)
public void testTaskLogAppender(){
TaskLogAppender appender= new TaskLogAppender();
System.setProperty(TaskLogAppender.TASKID_PROPERTY,"attempt_01_02_m03_04_001");
System.setProperty(TaskLogAppender.LOGSIZE_PROPERTY, "1003");
appender.activateOptions();
assertEquals(appender.getTaskId(), "attempt_01_02_m03_04_001");
assertEquals(appender.getTotalLogFileSize(),1000);
assertEquals(appender.getIsCleanup(),false);
// test writer
Writer writer= new StringWriter();
appender.setWriter(writer);
Layout layout = new PatternLayout("%-5p [%t]: %m%n");
appender.setLayout(layout);
Category logger= Logger.getLogger(getClass().getName());
LoggingEvent event = new LoggingEvent("fqnOfCategoryClass", logger, Priority.INFO, "message", new Throwable());
appender.append(event);
appender.flush() ;
appender.close();
assertTrue(writer.toString().length()>0);
// test cleanup should not changed
appender= new TaskLogAppender();
appender.setIsCleanup(true);
appender.activateOptions();
assertEquals(appender.getIsCleanup(),true);
}
protected
boolean isHandledType(Class type) {
return String.class.isAssignableFrom(type) ||
Integer.TYPE.isAssignableFrom(type) ||
Long.TYPE.isAssignableFrom(type) ||
Boolean.TYPE.isAssignableFrom(type) ||
Priority.class.isAssignableFrom(type);
}
/**
* Sets the priority to filter events on. Only events of equal or higher
* property are now displayed.
*
* @param aPriority the priority to filter on
*/
public void setPriorityFilter(Priority aPriority) {
synchronized (mLock) {
mPriorityFilter = aPriority;
updateFilteredEvents(false);
}
}
public String convert(LoggingEvent event) {
if (event.getLevel().toInt() == Priority.ERROR_INT) {
return "N" + Tracing.nodeId + "-E" + String.valueOf(errorCounter.incrementAndGet());
} else if (event.getLevel().toInt() == Priority.WARN_INT) {
return "N" + Tracing.nodeId + "-W" + String.valueOf(warnCounter.incrementAndGet());
} else if (event.getLevel().toInt() == Priority.INFO_INT) {
return "N" + Tracing.nodeId + "-I" + String.valueOf(infoCounter.incrementAndGet());
} else if (event.getLevel().toInt() == Priority.DEBUG_INT) {
return "N" + Tracing.nodeId + "-D" + String.valueOf(debugCounter.incrementAndGet());
}
return "n/a";
}
/**
* Tests LoggingEvent.level.
* @deprecated
*/
public void testLevel() {
Category root = Logger.getRootLogger();
Priority info = Level.INFO;
String catName = Logger.class.toString();
LoggingEvent event =
new LoggingEvent(
catName, root, 0L, info, "Hello, world.", null);
Priority error = Level.ERROR;
event.level = error;
assertEquals(Level.ERROR, event.level);
}
public
void actionPerformed(ActionEvent e) {
System.out.println("Action occured");
LoggingEvent event = new LoggingEvent("x", cat, Priority.DEBUG,
"Message "+j, null);
if(j % 5 == 0) {
//event.throwable = new Exception("hello "+j);
}
j++;
appender.add(event);
}
@AfterClass
public static void teardown()
{
for (Map.Entry<AppenderSkeleton, Priority> e : appenderLevelMap.entrySet()) {
e.getKey().setThreshold(e.getValue());
}
}
/** internal helper method which takes care of the actual modifying of the ip to loglevel/appender map **/
private void setLogLevelAndAppenderForRemoteAddr(String remoteAddr, Priority level, Appender appender) {
if (level == null) {
remoteAddrs2LogConfigs.remove(remoteAddr);
} else {
remoteAddrs2LogConfigs.put(remoteAddr, new LogConfig(level, appender));
}
}
/**
* Convert <code>val</code> a String parameter to an object of a
* given type.
*/
protected Object convertArg(String val, Class type) {
if (val == null) {
return null;
}
String v = val.trim();
if (String.class.isAssignableFrom(type)) {
return val;
} else if (Integer.TYPE.isAssignableFrom(type)) {
return Integer.parseInt(v);
} else if (Long.TYPE.isAssignableFrom(type)) {
return Long.parseLong(v);
} else if (Boolean.TYPE.isAssignableFrom(type)) {
if ("true".equalsIgnoreCase(v)) {
return Boolean.TRUE;
} else if ("false".equalsIgnoreCase(v)) {
return Boolean.FALSE;
}
} else if (Priority.class.isAssignableFrom(type)) {
return org.apache.log4j.helpers.OptionConverter.toLevel(v, Level.DEBUG);
} else if (ErrorHandler.class.isAssignableFrom(type)) {
return OptionConverter.instantiateByClassName(v,
ErrorHandler.class, null);
}
return null;
}
@Override
public HandlerResult handleNotification(PeerAddressChangeNotification notification, AssociationImpl associtaion) {
//associtaion.peerSocketAddress = notification.address();
if(logger.isEnabledFor(Priority.WARN)){
logger.warn(String.format("Peer Address changed to=%s for Association=%s", notification.address(), associtaion.getName()));
}
return HandlerResult.CONTINUE;
}
/**
* Initialises the timestamp to Esper-Time
*/
protected void forcedLog(String fqcn, Priority level, Object message, Throwable t) {
long time = System.currentTimeMillis();
try {
String strategyName = StrategyUtil.getStartedStrategyName();
RuleService ruleService = ServiceLocator.commonInstance().getRuleService();
if (ruleService.isInitialized(strategyName) && !ruleService.isInternalClock(strategyName)) {
time = ruleService.getCurrentTime(strategyName);
}
} catch (Exception e) {
// do nothing spring services are probably not initialized yet
}
callAppenders(new LoggingEvent(fqcn, this, time, level, message, t));
}
@Override
public void l7dlog(Priority priority, String key, Throwable t) {
if (isForcedToLog(priority)) {
// from super.l7dlog:
String msg = getResourceBundleString(key);
// if message corresponding to 'key' could not be found in the
// resource bundle, then default to 'key'.
if (msg == null) {
msg = key;
}
final Appender forcedAppender = getForcedAppender();
// force the logging and modify the log message (the latter might return the original message)
if (forcedAppender != null) {
// only call the forced appender
forcedAppender.doAppend(new LoggingEvent(FQCN, this, priority, modifyLogMessage(msg), t));
} else {
// go via the normal appenders
forcedLog(FQCN, priority, modifyLogMessage(msg), t);
}
} else {
super.l7dlog(priority, key, t);
}
}
@Test
public void testNoThrowableSuccess() throws Exception
{
CassandraAppender appender = new CassandraAppender();
LoggingEvent event = new LoggingEvent(BasicTest.class.getName(),
Category.getInstance(BasicTest.class),
Priority.WARN,
"test 12",
null);
appender.doAppend(event);
}
/**
* Creates a AWSJob Queue corresponding to the description in the JSON file conforming to AWS
* Batch HTTP specification
*
* @param json the file
* @param computeEnvironmentArn the CE ARN to assign if it does not exist
* @param name the name to assign if does not exist
* @return job queue ARN
*/
public String createQueue(File json, String computeEnvironmentArn, String name) {
// CreateJobQueueRequest jobQueueRequest =getTestJobQueueRequest( mPrefix ,
// JOB_QUEUE_SUFFIX, computeEnvironmentArn );
CreateJobQueueRequest jobQueueRequest =
new JobQueue().createJobQueueRequestFromHTTPSpec(json, computeEnvironmentArn, name);
CreateJobQueueResponse jobQueueResponse = mBatchClient.createJobQueue(jobQueueRequest);
String arn = jobQueueResponse.jobQueueArn();
mLogger.info("Created Job Queue " + arn);
mLogger.debug("Created Job Queue " + jobQueueResponse);
boolean valid = false;
int retry = 0;
long sleepTime = 2 * 1000;
while (!valid && retry < 3) {
// query to see if it has been enabled
DescribeJobQueuesRequest describeJobQueue =
DescribeJobQueuesRequest.builder().jobQueues(arn).build();
DescribeJobQueuesResponse describeJQResponse =
mBatchClient.describeJobQueues(describeJobQueue);
for (JobQueueDetail detail : describeJQResponse.jobQueues()) {
mLogger.debug(detail.jobQueueArn() + "," + detail.state() + "," + detail.status());
valid = detail.status().equals(JQStatus.VALID.toString());
}
try {
Thread.sleep(sleepTime);
} catch (InterruptedException ex) {
mLogger.log(Priority.ERROR, null, ex);
}
}
if (!valid) {
throw new RuntimeException("Job Queue still not valid after 3 retries " + arn);
}
return arn;
}
private void printWithMessage(String message, JexlNode node) {
printWithMessage(message, node, Priority.toPriority(Level.TRACE_INT));
}
private void printWithMessage(String message, JexlNode node, Priority priority) {
if (log.isEnabledFor(priority)) {
log.log(priority, message + ":" + PrintingVisitor.formattedQueryString(node));
log.log(priority, JexlStringBuildingVisitor.buildQuery(node));
}
}
@Override
@SuppressWarnings("deprecation")
public Priority getChainedPriority() {
return log.getChainedPriority();
}
@Override
public void log(Priority priority, Object message, Throwable t) {
threadLocalAwareLog(FQCN, priority, message, t);
}