Java 类ch.qos.logback.core.encoder.EchoEncoder 实例源码

@Before
public void setUp() throws Exception {
  encoder = new EchoEncoder<Object>();
  File outputDir = new File(outputDirStr);
  outputDir.mkdirs();

  System.out.println("Output dir [" + outputDirStr + "]");

  scriptOS = openScript();

  rfa.setName("rolling");
  rfa.setEncoder(encoder);
  rfa.setContext(context);
  rfa.setFile(outputDirStr + "output.log");

}

@Before
public void setUp() throws IOException, InterruptedException {
  if (!isConformingHost()) {
    return;
  }
  Process p = runLoopFSScript(LoopFSCommand.setup);
  p.waitFor();

  dump("/tmp/loopfs.log");

  fa.setContext(context);
  File outputDir = new File(outputDirStr);
  outputDir.mkdirs();
  System.out.println("FileAppenderResilienceTest output dir [" + outputDirStr
      + "]");

  fa.setName("FILE");
  fa.setEncoder(new EchoEncoder<Object>());
  fa.setFile(logfileStr);
  fa.start();
}

@Test
  public void wrongTarget() {
    ConsoleAppender<Object> ca = (ConsoleAppender<Object>) getAppender();
    EchoEncoder<Object> encoder = new EchoEncoder<Object>();
    encoder.setContext(context);
    ca.setContext(context);
    ca.setTarget("foo");
    ca.setEncoder(encoder);
    ca.start();
    ca.doAppend("a");
    StatusChecker checker = new StatusChecker(context);
    //21:28:01,246 + WARN in ch.qos.logback.core.ConsoleAppender[null] - [foo] should be one of [SystemOut, SystemErr]
    //21:28:01,246   |-WARN in ch.qos.logback.core.ConsoleAppender[null] - Using previously set target, System.out by default.
//    StatusPrinter.print(context);

    checker.assertContainsMatch(Status.WARN, "\\[foo\\] should be one of \\[SystemOut, SystemErr\\]");

  }

@Test
public void itActuallyWorks() throws Exception {
    logFile = File.createTempFile(getClass().getSimpleName(), ".log");
    rotatedLogFile = new File(logFile.getPath() + ".1");

    RotatableFileAppender<String> appender = new RotatableFileAppender<String>();
    appender.setEncoder(new EchoEncoder<String>());
    appender.setFile(logFile.getPath());
    appender.setCheckCachePeriod(0);

    appender.start();

    appender.doAppend("event 1");
    logFile.renameTo(rotatedLogFile);
    appender.doAppend("event 2");

    appender.stop();

    assertEquals("event 1", readTheSingleLineWhichComprises(rotatedLogFile));
    assertEquals("event 2", readTheSingleLineWhichComprises(logFile));
}

@Before
public void setUp() throws InterruptedException {

  context.getStatusManager().add(new OnConsoleStatusListener());

  File outputDir = new File(outputDirStr);
  outputDir.mkdirs();

  fa.setContext(context);
  fa.setName("FILE");
  fa.setEncoder(new EchoEncoder<Object>());
  fa.setFile(logfileStr);
  fa.start();
}

@Before
public void setUp() throws InterruptedException {
  context.getStatusManager().add(new OnConsoleStatusListener());

  File outputDir = new File(outputDirStr);
  outputDir.mkdirs();

  fa.setContext(context);
  fa.setName("FILE");
  fa.setPrudent(true);
  fa.setEncoder(new EchoEncoder<Object>());
  fa.setFile(logfileStr);
  fa.start();
}

@Before
public void setUp() throws Exception {
  encoder = new EchoEncoder<Object>();
  // if this this the fist test run after 'build clean up' then the
  // OUTPUT_DIR_PREFIX might be not yet created
  randomOutputDir.mkdirs();
}

@Test
public void changeInConsole() {
  ConsoleAppender<Object> ca = (ConsoleAppender<Object>) getAppender();
  EchoEncoder<Object> encoder = new EchoEncoder<Object>();
  ca.setEncoder(encoder);
  ca.start();
  ca.doAppend("a");
  assertEquals("a" + CoreConstants.LINE_SEPARATOR, tee.toString());

  XTeeOutputStream newTee = new XTeeOutputStream(null);
  System.setOut(new PrintStream(newTee));
  ca.doAppend("b");
  assertEquals("b" + CoreConstants.LINE_SEPARATOR, newTee.toString());
}

public IO(boolean _buffered, boolean _immediateFlush, long _len) {
  this.len = _len;
  this.buffered = _buffered;
  this.immediateFlush = _immediateFlush;
  context = new LoggerContext();
  logger = context.getLogger("logger-" + getName());

  // A FileAppender is created according to the buffering and
  // immediate flush setting of this IO instance.
  FileAppender<ILoggingEvent> fa = new FileAppender<ILoggingEvent>();

  if (longMessage) {
    PatternLayoutEncoder pa = new PatternLayoutEncoder();
    pa.setPattern("%r %5p %c [%t] - %m%n");
    pa.setContext(context);
    pa.start();
    fa.setEncoder(pa);
  } else {
    fa.setEncoder(new EchoEncoder<ILoggingEvent>());
  }

  fa.setFile(getName() + ".log");
  fa.setAppend(false);
  fa.setContext(context);
  fa.start();

}