@Test public void invalidCharset() throws IOException, InterruptedException { String file = FileSystem.createTemporaryFile(); new RollingFileWriter(doubletonMap("file", file, "charset", "UTF-42")).close(); assertThat(systemStream.consumeErrorOutput()).containsOnlyOnce("ERROR").containsOnlyOnce("charset").containsOnlyOnce("UTF-42"); }
@Override public void close() throws IOException, InterruptedException { if (writingThread) { internalClose(); } else { synchronized (writer) { internalClose(); } } }
RollingFileWriter extends AbstractFormatPatternWriter { @Override public void close() throws IOException, InterruptedException { if (writingThread) { internalClose(); } else { synchronized (writer) { internalClose(); } } } }
RollingFileWriter extends AbstractFormatPatternWriter { @Override public void close() throws IOException, InterruptedException { if (writingThread) { internalClose(); } else { synchronized (writer) { internalClose(); } } } RollingFileWriter();  RollingFileWriter(final Map<String, String> properties); }
RollingFileWriter extends AbstractFormatPatternWriter { @Override public void close() throws IOException, InterruptedException { if (writingThread) { internalClose(); } else { synchronized (writer) { internalClose(); } } } RollingFileWriter();  RollingFileWriter(final Map<String, String> properties); @Override void write(final LogEntry logEntry); @Override void flush(); @Override void close(); }
RollingFileWriter extends AbstractFormatPatternWriter { @Override public void close() throws IOException, InterruptedException { if (writingThread) { internalClose(); } else { synchronized (writer) { internalClose(); } } } RollingFileWriter();  RollingFileWriter(final Map<String, String> properties); @Override void write(final LogEntry logEntry); @Override void flush(); @Override void close();  }