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

x33g5p2x  于2022-02-01 转载在 其他  
字(7.0k)|赞(0)|评价(0)|浏览(255)

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

UnsynchronizedAppenderBase.start介绍

暂无

代码示例

代码示例来源:origin: line/armeria

@Override
public void start() {
  if (!aai.iteratorForAppenders().hasNext()) {
    addWarn("No appender was attached to " + getClass().getSimpleName() + '.');
  }
  if (exporter == null) {
    exporter = builder.build();
  }
  super.start();
}

代码示例来源:origin: googleapis/google-cloud-java

/** Initialize and configure the cloud logging service. */
@Override
public synchronized void start() {
 if (isStarted()) {
  return;
 }
 MonitoredResource resource = getMonitoredResource(getProjectId());
 defaultWriteOptions =
   new WriteOption[] {WriteOption.logName(getLogName()), WriteOption.resource(resource)};
 getLogging().setFlushSeverity(severityFor(getFlushLevel()));
 loggingEnhancers = new ArrayList<>();
 List<LoggingEnhancer> resourceEnhancers = MonitoredResourceUtil.getResourceEnhancers();
 loggingEnhancers.addAll(resourceEnhancers);
 loggingEnhancers.addAll(getLoggingEnhancers());
 loggingEventEnhancers = new ArrayList<>();
 loggingEventEnhancers.addAll(getLoggingEventEnhancers());
 super.start();
}

代码示例来源:origin: prometheus/client_java

@Override
public void start() {
 super.start();
}

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

@Override
public void start() {
 if (connectionSource == null) {
  throw new IllegalStateException(
    "DBAppender cannot function without a connection source");
 }
 sqlDialect = DBUtil
   .getDialectFromCode(connectionSource.getSQLDialectCode());
 if (getGeneratedKeysMethod() != null) {
  cnxSupportsGetGeneratedKeys = connectionSource.supportsGetGeneratedKeys();
 } else {
  cnxSupportsGetGeneratedKeys = false;
 }
 cnxSupportsBatchUpdates = connectionSource.supportsBatchUpdates();
 if (!cnxSupportsGetGeneratedKeys && (sqlDialect == null)) {
  throw new IllegalStateException(
    "DBAppender cannot function if the JDBC driver does not support getGeneratedKeys method *and* without a specific SQL dialect");
 }
 // all nice and dandy on the eastern front
 super.start();
}

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

/**
 * Checks that requires parameters are set and if everything is in order,
 * activates this appender.
 */
public void start() {
 int errors = 0;
 if (this.encoder == null) {
  addStatus(new ErrorStatus("No encoder set for the appender named \""
    + name + "\".", this));
  errors++;
 }
 if (this.outputStream == null) {
  addStatus(new ErrorStatus(
    "No output stream set for the appender named \"" + name + "\".", this));
  errors++;
 }
 // only error free appenders should be activated
 if (errors == 0) {
  super.start();
 }
}

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

@Override
public void start() {
 if (appenderCount == 0) {
  addError("No attached appenders found.");
  return;
 }
 if (queueSize < 1) {
  addError("Invalid queue size [" + queueSize + "]");
  return;
 }
 blockingQueue = new ArrayBlockingQueue<E>(queueSize);
 if (discardingThreshold == UNDEFINED)
  discardingThreshold = queueSize / 5;
 addInfo("Setting discardingThreshold to " + discardingThreshold);
 worker.setDaemon(true);
 worker.setName("AsyncAppender-Worker-" + worker.getName());
 // make sure this instance is marked as "started" before staring the worker Thread
 super.start();
 worker.start();
}

代码示例来源:origin: io.prometheus/simpleclient_logback

@Override
public void start() {
 super.start();
}

代码示例来源:origin: com.bugsnag/bugsnag

@Override
public void start() {
  this.bugsnag = createBugsnag();
  super.start();
}

代码示例来源:origin: bugsnag/bugsnag-java

@Override
public void start() {
  this.bugsnag = createBugsnag();
  super.start();
}

代码示例来源:origin: line/centraldogma

@Override
public void start() {
  if (!aai.iteratorForAppenders().hasNext()) {
    addWarn("No appender was attached to " + getClass().getSimpleName() + '.');
  }
  super.start();
}

代码示例来源:origin: aliyun/aliyun-log-logback-appender

private void doStart() {
  formatter = DateTimeFormat.forPattern(timeFormat).withZone(DateTimeZone.forID(timeZone));
  producerConfig.userAgent = "logback";
  producer = new LogProducer(producerConfig);
  producer.setProjectConfig(projectConfig);
  super.start();
}

代码示例来源:origin: qos-ch/logback-extensions

@Override
public void start() {
  if (isStarted()) {
    return;
  }
  if (beanName == null || beanName.trim().isEmpty()) {
    if (name == null || name.trim().isEmpty()) {
      throw new IllegalStateException("A 'name' or 'beanName' is required for DelegatingLogbackAppender");
    }
    beanName = name;
  }
  cache = cacheMode.createCache();
  super.start();
}

代码示例来源:origin: internetitem/logback-elasticsearch-appender

@Override
public void start() {
  super.start();
  this.errorReporter = getErrorReporter();
  try {
    this.publisher = buildElasticsearchPublisher();
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源:origin: kmtong/logback-redis-appender

@Override
public void start() {
  super.start();
  GenericObjectPoolConfig config = new GenericObjectPoolConfig();
  config.setTestOnBorrow(true);
  pool = new JedisPool(config, host, port, timeout, password, database);
}

代码示例来源:origin: com.linecorp.armeria/armeria-logback

@Override
public void start() {
  if (!aai.iteratorForAppenders().hasNext()) {
    addWarn("No appender was attached to " + getClass().getSimpleName() + '.');
  }
  if (exporter == null) {
    exporter = builder.build();
  }
  super.start();
}

代码示例来源:origin: com.linecorp.armeria/armeria-logback-shaded

@Override
public void start() {
  if (!aai.iteratorForAppenders().hasNext()) {
    addWarn("No appender was attached to " + getClass().getSimpleName() + '.');
  }
  if (exporter == null) {
    exporter = builder.build();
  }
  super.start();
}

代码示例来源:origin: getheimdall/heimdall

@Override
public void start() {
  log.info("Initializing Mongodb Appender");
  if (this.uri != null) {
    this.mongoClient = new MongoClient(new MongoClientURI(this.uri));
  } else {
    MongoClientOptions options = new MongoClientOptions.Builder().build();
    ServerAddress address = new ServerAddress(this.url, this.port.intValue());
    this.mongoClient = new MongoClient(address, options);
  }
  MongoDatabase database = this.mongoClient.getDatabase(this.dataBase);
  this.collection = database.getCollection(this.collectionName);
  log.info("Starting connection with url: {} - port: {}", this.url, this.port);
  log.info("Database used: {} - Collection: {}", this.dataBase, this.collectionName);
  super.start();
}

代码示例来源:origin: gofore/aws-training

@Override
public void start() {
  lock.lock();
  
  if (queueUrl == null) {
    addError("Logging queue not set for appender '" + name + "'");
    return;
  }
  
  try {
    close();
    this.sqs = initSqs();
    super.start();
  } finally {
    lock.unlock();
  }
}

代码示例来源:origin: com.alibaba.citrus.tool/antx-autoexpand

@Override
public void start() {
 int errors = 0;
 if (discriminator == null) {
  addError("Missing discriminator. Aborting");
  errors++;
 }
 if (!discriminator.isStarted()) {
  addError("Discriminator has not started successfully. Aborting");
  errors++;
 }
 if (errors == 0) {
  super.start();
 }
}

代码示例来源:origin: io.digdag/digdag-cli

@Override
public void start()
{
  if (isStarted()) {
    return;
  }
  PatternLayout patternLayout = new PatternLayout();
  patternLayout.setContext(context);
  patternLayout.setPattern(PATTERN);
  patternLayout.setOutputPatternAsHeader(false);
  patternLayout.start();
  this.layout = patternLayout;
  super.start();
}

相关文章