org.apache.logging.log4j.Logger.isInfoEnabled()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(10.4k)|赞(0)|评价(0)|浏览(390)

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

Logger.isInfoEnabled介绍

[英]Checks whether this Logger is enabled for the Level#INFO Level.
[中]检查是否为级别#信息级别启用此记录器。

代码示例

代码示例来源：origin: apache/geode

  1. private void debug(String message, Object... params) {
  2.  if (logger.isDebugEnabled()) {
  3.   logger.debug(message, params);
  4.  } else if (logger.isInfoEnabled() && DEBUG) {
  5.   logger.info(message, params);
  6.  }
  7. }

代码示例来源：origin: javamelody/javamelody

  1. /** {@inheritDoc} */
  2. @Override
  3. public void logHttpRequest(HttpServletRequest httpRequest, String requestName, long duration,
  4.     boolean systemError, int responseSize, String loggerName) {
  5.   final org.apache.logging.log4j.Logger logger = org.apache.logging.log4j.LogManager
  6.       .getLogger(loggerName);
  7.   if (logger.isInfoEnabled()) {
  8.     logger.info(LOG.buildLogMessage(httpRequest, duration, systemError, responseSize));
  9.   }
  10. }

代码示例来源：origin: apache/geode

  1. @Override
  2. public CacheRuntimeException createCancelationException(final long timeLimitMillis,
  3.   final DefaultQuery query) {
  4.  final String message = String.format(
  5.    "Query execution canceled after exceeding max execution time %sms.",
  6.    timeLimitMillis);
  7.  if (logger.isInfoEnabled()) {
  8.   logger.info(String.format("%s %s", message, query));
  9.  }
  10.  return new QueryExecutionTimeoutException(message);
  11. }

代码示例来源：origin: apache/geode

  1. private void handleMemberDeparture(InternalDistributedMember member) {
  2.  Integer queueId = getQueueId(member, false);
  3.  if (queueId == null) {
  4.   return;
  5.  }
  6.  boolean isUsed = false;
  7.  synchronized (senderToSerialQueueIdMap) {
  8.   senderToSerialQueueIdMap.remove(member);
  9.   // Check if any other members are using the same executor.
  10.   for (Iterator iter = senderToSerialQueueIdMap.values().iterator(); iter.hasNext();) {
  11.    Integer value = (Integer) iter.next();
  12.    if (value.equals(queueId)) {
  13.     isUsed = true;
  14.     break;
  15.    }
  16.   }
  17.   // If not used mark this as unused.
  18.   if (!isUsed) {
  19.    if (logger.isInfoEnabled(LogMarker.DM_MARKER))
  20.     logger.info(LogMarker.DM_MARKER,
  21.       "Marking the SerialQueuedExecutor with id : {} used by the member {} to be unused.",
  22.       new Object[] {queueId, member});
  23.    threadMarkedForUse.add(queueId);
  24.   }
  25.  }
  26. }

代码示例来源：origin: apache/geode

  1. public PdxType getType(int typeId) {
  2.  PdxType pdxType = this.idToType.get(typeId);
  3.  if (pdxType != null) {
  4.   return pdxType;
  5.  }
  6.  synchronized (this) {
  7.   pdxType = this.distributedTypeRegistry.getType(typeId);
  8.   if (pdxType != null) {
  9.    this.idToType.put(typeId, pdxType);
  10.    this.typeToId.put(pdxType, typeId);
  11.    if (logger.isInfoEnabled()) {
  12.     logger.info("Adding: {}", pdxType.toFormattedString());
  13.    }
  14.    if (logger.isDebugEnabled()) {
  15.     logger.debug("Adding entry into pdx type registry, typeId: {}  {}", typeId, pdxType);
  16.    }
  17.    return pdxType;
  18.   }
  19.  }
  20.  return null;
  21. }

代码示例来源：origin: apache/geode

  1. public int defineEnum(EnumInfo newInfo) {
  2.  Integer existingId = this.enumInfoToId.get(newInfo);
  3.  if (existingId != null) {
  4.   return existingId;
  5.  }
  6.  int id = this.distributedTypeRegistry.defineEnum(newInfo);
  7.  EnumInfo oldInfo = this.idToEnum.get(id);
  8.  if (oldInfo == null) {
  9.   this.idToEnum.put(id, newInfo);
  10.   this.enumInfoToId.put(newInfo, id);
  11.   if (logger.isInfoEnabled()) {
  12.    logger.info("Caching PDX Enum: {}, dsid={} typenum={}", newInfo, id >> 24, id & 0xFFFFFF);
  13.   }
  14.  } else if (!oldInfo.equals(newInfo)) {
  15.   Assert.fail("Old enum does not equal new enum for the same id. oldEnum=" + oldInfo
  16.     + " newEnum=" + newInfo);
  17.  }
  18.  return id;
  19. }

代码示例来源：origin: apache/geode

  1. public void addRemoteType(int typeId, PdxType newType) {
  2.  PdxType oldType = this.idToType.get(typeId);
  3.  if (oldType == null) {
  4.   this.distributedTypeRegistry.addRemoteType(typeId, newType);
  5.   this.idToType.put(typeId, newType);
  6.   this.typeToId.put(newType, typeId);
  7.   if (logger.isInfoEnabled()) {
  8.    logger.info("Adding, from remote WAN: {}", newType.toFormattedString());
  9.   }
  10.  } else if (!oldType.equals(newType)) {
  11.   Assert.fail("Old type does not equal new type for the same id. oldType=" + oldType
  12.     + " new type=" + newType);
  13.  }
  14. }

代码示例来源：origin: apache/geode

  1. private void initializeServerSocket() throws IOException {
  2.  if (srv_sock == null || srv_sock.isClosed()) {
  3.   if (bind_address == null) {
  4.    srv_sock = getSocketCreator().createServerSocket(port, BACKLOG);
  5.    bind_address = srv_sock.getInetAddress();
  6.   } else {
  7.    srv_sock = getSocketCreator().createServerSocket(port, BACKLOG, bind_address);
  8.   }
  9.   // GEODE-4176 - set the port from a wild-card bind so that handlers know the correct value
  10.   if (this.port <= 0) {
  11.    this.port = srv_sock.getLocalPort();
  12.   }
  13.   if (log.isInfoEnabled()) {
  14.    log.info("Locator was created at " + new Date());
  15.    log.info("Listening on port " + getPort() + " bound on address " + bind_address);
  16.   }
  17.   srv_sock.setReuseAddress(true);
  18.  }
  19. }

代码示例来源：origin: apache/geode

  1. public void addImportedType(int typeId, PdxType importedType) {
  2.  PdxType existing = getType(typeId);
  3.  if (existing != null && !existing.equals(importedType)) {
  4.   throw new PdxSerializationException(
  5.     String.format(
  6.       "Detected conflicting PDX types during import:%s%sSnapshot data containing PDX types must be imported into an empty cache with no pre-existing type definitions. Allow the import to complete prior to inserting additional data into the cache.",
  7.       importedType, existing));
  8.  }
  9.  this.distributedTypeRegistry.addImportedType(typeId, importedType);
  10.  this.idToType.put(typeId, importedType);
  11.  this.typeToId.put(importedType, typeId);
  12.  if (logger.isInfoEnabled()) {
  13.   logger.info("Importing type: {}", importedType.toFormattedString());
  14.  }
  15. }

代码示例来源：origin: apache/geode

  1. /**
  2.  * Create a type id for a type that may come locally, or from a remote member.
  3.  */
  4. public int defineType(PdxType newType) {
  5.  Integer existingId = this.typeToId.get(newType);
  6.  if (existingId != null) {
  7.   int eid = existingId;
  8.   newType.setTypeId(eid);
  9.   return eid;
  10.  }
  11.  int id = this.distributedTypeRegistry.defineType(newType);
  12.  newType.setTypeId(id);
  13.  PdxType oldType = this.idToType.get(id);
  14.  if (oldType == null) {
  15.   this.idToType.put(id, newType);
  16.   this.typeToId.put(newType, id);
  17.   if (logger.isInfoEnabled()) {
  18.    logger.info("Caching {}", newType.toFormattedString());
  19.   }
  20.  } else if (!oldType.equals(newType)) {
  21.   Assert.fail("Old type does not equal new type for the same id. oldType=" + oldType
  22.     + " new type=" + newType);
  23.  }
  24.  return id;
  25. }

代码示例来源：origin: apache/geode

  1. pool.getStats().setLocatorCount(newLocatorAddresses.size());
  2. if (logger.isInfoEnabled()
  3.   || !locatorCallback.getClass().equals(LocatorDiscoveryCallbackAdapter.class)) {
  4.  List<InetSocketAddress> newLocators = newLocatorList.getLocators();
  5.  if (!addedLocators.isEmpty()) {
  6.   locatorCallback.locatorsDiscovered(Collections.unmodifiableList(addedLocators));
  7.   logger.info("AutoConnectionSource discovered new locators {}",
  8.     addedLocators);
  9.   logger.info("AutoConnectionSource dropping previously discovered locators {}",
  10.     removedLocators);

代码示例来源：origin: apache/geode

  1. if (logger.isInfoEnabled()) {
  2.  logger.info(
  3.    "ClientStatsManager, intializing the statistics...");

代码示例来源：origin: apache/geode

  1. if (prQueryTraceInfoList != null && this.query.isTraced() && logger.isInfoEnabled()) {
  2.  if (DefaultQuery.testHook != null) {
  3.   DefaultQuery.testHook
  4.   sb.append(queryTraceInfo.createLogLine(me)).append("\n");
  5.  logger.info(sb.toString());;

代码示例来源：origin: apache/geode

  1. logger.info("Did not hear back from any other system. I am the first one.");
  2.   } else if (transport.isMcastEnabled()) {
  3. if (logger.isInfoEnabled()) {
  4.  long delta = System.currentTimeMillis() - start;
  5.  Object[] logArgs = new Object[] {distributionManager.getDistributionManagerId(), transport,
  6.    Integer.valueOf(distributionManager.getOtherDistributionManagerIds().size()),
  7.    distributionManager.getOtherDistributionManagerIds(),
  8.    (logger.isInfoEnabled(LogMarker.DM_MARKER) ? " (VERBOSE, took " + delta + " ms)" : ""),
  9.    ((distributionManager.getDMType() == ADMIN_ONLY_DM_TYPE) ? " (admin only)"
  10.      : (distributionManager.getDMType() == LOCATOR_DM_TYPE) ? " (locator)" : "")};
  11.  logger.info(LogMarker.DM_MARKER,
  12.    "DistributionManager {} started on {}. There were {} other DMs. others: {} {} {}",
  13.    logArgs);

代码示例来源：origin: apache/geode

  1. logger.info("[ThreadsMonitor] a New Monitor object and process were created.\n");
  2. } else {
  3.  this.threadMonitor = new ThreadsMonitoringImplDummy();
  4.  logger.info("[ThreadsMonitor] Monitoring is disabled and will not be run.\n");
  5.  if (logger.isInfoEnabled(LogMarker.DM_MARKER)) {
  6.   logger.info(LogMarker.DM_MARKER,
  7.     "Serial Queue info :" + " THROTTLE_PERCENT: " + THROTTLE_PERCENT
  8.       + " SERIAL_QUEUE_BYTE_LIMIT :" + SERIAL_QUEUE_BYTE_LIMIT
  9. logger.info("Starting DistributionManager {}. {}",
  10.   new Object[] {this.localAddress,
  11.     (logger.isInfoEnabled(LogMarker.DM_MARKER) ? sb.toString() : "")});

代码示例来源：origin: banq/jdonframework

  1. private static void uselog4j3(Throwable t, String msg, String module) {
  2.   Logger logger = getLogger(module);
  3.   if (logger.isInfoEnabled())
  4.     logger.info(msg.intern(), t);
  5.   else
  6.     uselog4j4(t, msg, module);
  7. }

代码示例来源：origin: org.elasticsearch/elasticsearch

  1. static void logSettingUpdate(Setting setting, Settings current, Settings previous, Logger logger) {
  2.   if (logger.isInfoEnabled()) {
  3.     if (setting.isFiltered()) {
  4.       logger.info("updating [{}]", setting.key);
  5.     } else {
  6.       logger.info("updating [{}] from [{}] to [{}]", setting.key, setting.getRaw(previous), setting.getRaw(current));
  7.     }
  8.   }
  9. }

代码示例来源：origin: org.elasticsearch/elasticsearch

  1. @Override
  2. protected void doStart() {
  3.   transport.addMessageListener(this);
  4.   connectionManager.addListener(this);
  5.   transport.start();
  6.   if (transport.boundAddress() != null && logger.isInfoEnabled()) {
  7.     logger.info("{}", transport.boundAddress());
  8.     for (Map.Entry<String, BoundTransportAddress> entry : transport.profileBoundAddresses().entrySet()) {
  9.       logger.info("profile [{}]: {}", entry.getKey(), entry.getValue());
  10.     }
  11.   }
  12.   localNode = localNodeFactory.apply(transport.boundAddress());
  13.   if (connectToRemoteCluster) {
  14.     // here we start to connect to the remote clusters
  15.     remoteClusterService.initializeRemoteClusters();
  16.   }
  17. }

代码示例来源：origin: org.elasticsearch/elasticsearch

  1. } else if (logger.isInfoEnabled()) {
  2.   FsInfo.Path totFSPath = new FsInfo.Path();
  3.   Set<String> allTypes = new HashSet<>();
  4.   logger.info("using [{}] data paths, mounts [{}], net usable_space [{}], net total_space [{}], types [{}]",
  5.     nodePaths.length, allMounts, totFSPath.getAvailable(), totFSPath.getTotal(), toString(allTypes));

代码示例来源：origin: org.elasticsearch/elasticsearch

  1. static void logGcOverhead(
  2.   final Logger logger,
  3.   final JvmMonitor.Threshold threshold,
  4.   final long current,
  5.   final long elapsed,
  6.   final long seq) {
  7.   switch (threshold) {
  8.     case WARN:
  9.       if (logger.isWarnEnabled()) {
  10.         logger.warn(OVERHEAD_LOG_MESSAGE, seq, TimeValue.timeValueMillis(current), TimeValue.timeValueMillis(elapsed));
  11.       }
  12.       break;
  13.     case INFO:
  14.       if (logger.isInfoEnabled()) {
  15.         logger.info(OVERHEAD_LOG_MESSAGE, seq, TimeValue.timeValueMillis(current), TimeValue.timeValueMillis(elapsed));
  16.       }
  17.       break;
  18.     case DEBUG:
  19.       if (logger.isDebugEnabled()) {
  20.         logger.debug(OVERHEAD_LOG_MESSAGE, seq, TimeValue.timeValueMillis(current), TimeValue.timeValueMillis(elapsed));
  21.       }
  22.       break;
  23.   }
  24. }

内容来源于网络，如有侵权，请联系作者删除！

Logger

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com