package com.cloudera.flume.handlers.log4j;
import org.apache.log4j.Level;
import org.apache.log4j.spi.LoggingEvent;
import com.cloudera.flume.core.EventBaseImpl;
import com.cloudera.util.NetUtils;
LoggingEvent evt;
long nanos;
super();
this.evt = evt;
this.nanos = System.nanoTime();
}
return evt.getRenderedMessage().getBytes();
}
return level2prio(evt.getLevel());
}
if (l == Level.DEBUG)
return Priority.DEBUG;
if (l == Level.INFO)
return Priority.INFO;
if (l == Level.WARN)
return Priority.WARN;
if (l == Level.ERROR)
return Priority.ERROR;
if (l == Level.FATAL)
return Priority.FATAL;
return Priority.INFO;
}
return evt.getTimeStamp();
}
@Override
return nanos;
}
@Override
return NetUtils.localhost();
}
}