ch.qos.logback.core.OutputStreamAppender.isStarted()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.8k)|赞(0)|评价(0)|浏览(111)

本文整理了Java中ch.qos.logback.core.OutputStreamAppender.isStarted()方法的一些代码示例,展示了OutputStreamAppender.isStarted()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。OutputStreamAppender.isStarted()方法的具体详情如下:
包路径:ch.qos.logback.core.OutputStreamAppender
类名称:OutputStreamAppender
方法名:isStarted

OutputStreamAppender.isStarted介绍

暂无

代码示例

代码示例来源:origin: camunda/camunda-bpm-platform

@Override
protected void append(E eventObject) {
 if (!isStarted()) {
  return;
 }
 subAppend(eventObject);
}

代码示例来源:origin: camunda/camunda-bpm-platform

if (!isStarted()) {
 return;

代码示例来源:origin: tony19/logback-android

@Override
protected void append(E eventObject) {
 if (!isStarted()) {
  return;
 }
 subAppend(eventObject);
}

代码示例来源:origin: ch.qos.logback/core

@Override
protected void append(E eventObject) {
 if (!isStarted()) {
  return;
 }
 subAppend(eventObject);
}

代码示例来源:origin: at.bestsolution.efxclipse.eclipse/ch.qos.logback.core

@Override
protected void append(E eventObject) {
 if (!isStarted()) {
  return;
 }
 subAppend(eventObject);
}

代码示例来源:origin: com.hynnet/logback-core

@Override
protected void append(E eventObject) {
 if (!isStarted()) {
  return;
 }
 subAppend(eventObject);
}

代码示例来源:origin: io.virtdata/virtdata-lib-realer

@Override
protected void append(E eventObject) {
  if (!isStarted()) {
    return;
  }
  subAppend(eventObject);
}

代码示例来源:origin: com.impetus.fabric/fabric-jdbc-driver-shaded

@Override
protected void append(E eventObject) {
  if (!isStarted()) {
    return;
  }
  subAppend(eventObject);
}

代码示例来源:origin: Nextdoor/bender

@Override
protected void append(E eventObject) {
  if (!isStarted()) {
    return;
  }
  subAppend(eventObject);
}

代码示例来源:origin: com.hynnet/logback-core

if (!isStarted()) {
 return;

代码示例来源:origin: at.bestsolution.efxclipse.eclipse/ch.qos.logback.core

/**
 * Actual writing occurs here.
 * <p>
 * Most subclasses of <code>WriterAppender</code> will need to override this
 * method.
 * 
 * @since 0.9.0
 */
protected void subAppend(E event) {
 if (!isStarted()) {
  return;
 }
 try {
  // this step avoids LBCLASSIC-139
  if (event instanceof DeferredProcessingAware) {
   ((DeferredProcessingAware) event).prepareForDeferredProcessing();
  }
  // the synchronization prevents the OutputStream from being closed while we
  // are writing. It also prevents multiple threads from entering the same
  // converter. Converters assume that they are in a synchronized block.
  synchronized (lock) {
   writeOut(event);
  }
 } catch (IOException ioe) {
  // as soon as an exception occurs, move to non-started state
  // and add a single ErrorStatus to the SM.
  this.started = false;
  addStatus(new ErrorStatus("IO failure in appender", this, ioe));
 }
}

代码示例来源:origin: ch.qos.logback/core

/**
 * Actual writing occurs here.
 * <p>
 * Most subclasses of <code>WriterAppender</code> will need to override this
 * method.
 * 
 * @since 0.9.0
 */
protected void subAppend(E event) {
 if (!isStarted()) {
  return;
 }
 try {
  // this step avoids LBCLASSIC-139
  if (event instanceof DeferredProcessingAware) {
   ((DeferredProcessingAware) event).prepareForDeferredProcessing();
  }
  // the synchronization prevents the OutputStream from being closed while we
  // are writing. It also prevents multiple threads from entering the same
  // converter. Converters assume that they are in a synchronized block.
  synchronized (lock) {
   writeOut(event);
  }
 } catch (IOException ioe) {
  // as soon as an exception occurs, move to non-started state
  // and add a single ErrorStatus to the SM.
  this.started = false;
  addStatus(new ErrorStatus("IO failure in appender", this, ioe));
 }
}

代码示例来源:origin: Nextdoor/bender

/**
 * Actual writing occurs here.
 * <p>
 * Most subclasses of <code>WriterAppender</code> will need to override this
 * method.
 * 
 * @since 0.9.0
 */
protected void subAppend(E event) {
  if (!isStarted()) {
    return;
  }
  try {
    // this step avoids LBCLASSIC-139
    if (event instanceof DeferredProcessingAware) {
      ((DeferredProcessingAware) event).prepareForDeferredProcessing();
    }
    // the synchronization prevents the OutputStream from being closed while we
    // are writing. It also prevents multiple threads from entering the same
    // converter. Converters assume that they are in a synchronized block.
    // lock.lock();
    byte[] byteArray = this.encoder.encode(event);
    writeBytes(byteArray);
  } catch (IOException ioe) {
    // as soon as an exception occurs, move to non-started state
    // and add a single ErrorStatus to the SM.
    this.started = false;
    addStatus(new ErrorStatus("IO failure in appender", this, ioe));
  }
}

代码示例来源:origin: tony19/logback-android

if (!isStarted()) {
 return;

代码示例来源:origin: io.virtdata/virtdata-lib-realer

/**
 * Actual writing occurs here.
 * <p>
 * Most subclasses of <code>WriterAppender</code> will need to override this
 * method.
 * 
 * @since 0.9.0
 */
protected void subAppend(E event) {
  if (!isStarted()) {
    return;
  }
  try {
    // this step avoids LBCLASSIC-139
    if (event instanceof DeferredProcessingAware) {
      ((DeferredProcessingAware) event).prepareForDeferredProcessing();
    }
    // the synchronization prevents the OutputStream from being closed while we
    // are writing. It also prevents multiple threads from entering the same
    // converter. Converters assume that they are in a synchronized block.
    // lock.lock();
    byte[] byteArray = this.encoder.encode(event);
    writeBytes(byteArray);
  } catch (IOException ioe) {
    // as soon as an exception occurs, move to non-started state
    // and add a single ErrorStatus to the SM.
    this.started = false;
    addStatus(new ErrorStatus("IO failure in appender", this, ioe));
  }
}

代码示例来源:origin: com.impetus.fabric/fabric-jdbc-driver-shaded

/**
 * Actual writing occurs here.
 * <p>
 * Most subclasses of <code>WriterAppender</code> will need to override this
 * method.
 * 
 * @since 0.9.0
 */
protected void subAppend(E event) {
  if (!isStarted()) {
    return;
  }
  try {
    // this step avoids LBCLASSIC-139
    if (event instanceof DeferredProcessingAware) {
      ((DeferredProcessingAware) event).prepareForDeferredProcessing();
    }
    // the synchronization prevents the OutputStream from being closed while we
    // are writing. It also prevents multiple threads from entering the same
    // converter. Converters assume that they are in a synchronized block.
    // lock.lock();
    byte[] byteArray = this.encoder.encode(event);
    writeBytes(byteArray);
  } catch (IOException ioe) {
    // as soon as an exception occurs, move to non-started state
    // and add a single ErrorStatus to the SM.
    this.started = false;
    addStatus(new ErrorStatus("IO failure in appender", this, ioe));
  }
}

相关文章