本文整理了Java中ch.qos.logback.core.UnsynchronizedAppenderBase.start()
方法的一些代码示例,展示了UnsynchronizedAppenderBase.start()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。UnsynchronizedAppenderBase.start()
方法的具体详情如下:
包路径:ch.qos.logback.core.UnsynchronizedAppenderBase
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!