com.metamx.common.logger.Logger类的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(307)

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

Logger介绍

暂无

代码示例

代码示例来源：origin: com.metamx/emitter

  1. switch (level) {
  2.  case TRACE:
  3.   if (log.isTraceEnabled()) {
  4.    log.trace(message, started.get());
  5.   if (log.isDebugEnabled()) {
  6.    log.debug(message, started.get());
  7.   if (log.isInfoEnabled()) {
  8.    log.info(message, started.get());
  9.   log.warn(message, started.get());
  10.   break;
  11.  case ERROR:
  12.   log.error(message, started.get());
  13.   break;

代码示例来源：origin: com.metamx/java-util

  1. @Override
  2.  public void stop()
  3.  {
  4.   log.info("Stopping object[%s]", o);
  5.   try {
  6.    stopMethod.invoke(o);
  7.   }
  8.   catch (Exception e) {
  9.    log.error(e, "Unable to invoke stopMethod() on %s", o.getClass());
  10.   }
  11.  }
  12. }

代码示例来源：origin: metamx/java-util

  1. @Override
  2.  public void run()
  3.  {
  4.   try {
  5.    log.debug("Running %s (delay %s)", callable, delay);
  6.    if (callable.call() == Signal.REPEAT) {
  7.     log.debug("Rescheduling %s (delay %s)", callable, delay);
  8.     exec.schedule(this, delay.getMillis(), TimeUnit.MILLISECONDS);
  9.    } else {
  10.     log.debug("Stopped rescheduling %s (delay %s)", callable, delay);
  11.    }
  12.   }
  13.   catch (Throwable e) {
  14.    log.error(e, "Uncaught exception.");
  15.   }
  16.  }
  17. },

代码示例来源：origin: com.metamx/server-metrics

  1. @Override
  2.  public boolean doMonitor(ServiceEmitter emitter)
  3.  {
  4.   log.info("I am watching...");
  5.   return true;
  6.  }
  7. }

代码示例来源：origin: io.druid.extensions/druid-rabbitmq

  1. @Override
  2.  public void shutdownCompleted(ShutdownSignalException cause)
  3.  {
  4.   log.warn(cause, "Connection closed!");
  5.  }
  6. }

代码示例来源：origin: com.metamx/java-util

  1. public static void close(Closeable closeable)
  2.  {
  3.   if (closeable == null) {
  4.    return;
  5.   }
  6.   try {
  7.    closeable.close();
  8.   }
  9.   catch (IOException e) {
  10.    log.error(e, "IOException thrown while closing Closeable.");
  11.   }
  12.  }
  13. }

代码示例来源：origin: metamx/java-util

  1. @Override
  2. public void channelDisconnected(ChannelHandlerContext context, ChannelStateEvent event) throws Exception
  3. {
  4.  if (log.isDebugEnabled()) {
  5.   log.debug("[%s] Channel disconnected", requestDesc);
  6.  }
  7.  // response is non-null if we received initial chunk and then exception occurs
  8.  if (response != null) {
  9.   handler.exceptionCaught(response, new ChannelException("Channel disconnected"));
  10.  }
  11.  channel.close();
  12.  channelResourceContainer.returnResource();
  13.  if (!retVal.isDone()) {
  14.   log.warn("[%s] Channel disconnected before response complete", requestDesc);
  15.   retVal.setException(new ChannelException("Channel disconnected"));
  16.  }
  17.  context.sendUpstream(event);
  18. }

代码示例来源：origin: metamx/java-util

  1. @Override
  2. public ClientResponse<InputStream> done(ClientResponse<InputStream> clientResponse)
  3. {
  4.  synchronized (done) {
  5.   try {
  6.    // An empty byte array is put at the end to give the SequenceInputStream.close() as something to close out
  7.    // after done is set to true, regardless of the rest of the stream's state.
  8.    queue.put(ByteSource.empty().openStream());
  9.    log.debug("Added terminal empty stream");
  10.   }
  11.   catch (InterruptedException e) {
  12.    log.warn(e, "Thread interrupted while adding to queue");
  13.    Thread.currentThread().interrupt();
  14.    throw Throwables.propagate(e);
  15.   }
  16.   catch (IOException e) {
  17.    // This should never happen
  18.    log.wtf(e, "The empty stream threw an IOException");
  19.    throw Throwables.propagate(e);
  20.   }
  21.   finally {
  22.    log.debug("Done after adding %d bytes of streams", byteCount.get());
  23.    done.set(true);
  24.   }
  25.  }
  26.  return ClientResponse.<InputStream>finished(clientResponse.getObj());
  27. }

代码示例来源：origin: metamx/java-util

  1. @Test
  2.  public void testLegacyLogging()
  3.  {
  4.   final Logger log = new Logger(LoggerTest.class);
  5.   final Throwable throwable = new Throwable();
  6.   // These should show up in an IDE as deprecated, but shouldn't actually fail.
  7.   log.error("foo", throwable);
  8.   log.warn("foo", throwable);
  9.  }
  10. }

代码示例来源：origin: com.n3twork.druid/druid-indexing-service

  1. @Override
  2. public void unregister(final String service)
  3. {
  4.  log.info("Unregistering chat handler[%s]", service);
  5.  final ChatHandler handler = handlers.get(service);
  6.  if (handler == null) {
  7.   log.warn("handler[%s] not currently registered, ignoring.", service);
  8.  }
  9.  try {
  10.   serviceAnnouncer.unannounce(makeDruidNode(service));
  11.  }
  12.  catch (Exception e) {
  13.   log.warn(e, "Failed to unregister service[%s]", service);
  14.  }
  15.  handlers.remove(service, handler);
  16. }

代码示例来源：origin: com.metamx/java-util

  1. private static void awaitNextRetry(final Throwable e, final int nTry, final boolean quiet) throws InterruptedException
  2.  {
  3.   final long baseSleepMillis = 1000;
  4.   final long maxSleepMillis = 60000;
  5.   final double fuzzyMultiplier = Math.min(Math.max(1 + 0.2 * ThreadLocalRandom.current().nextGaussian(), 0), 2);
  6.   final long sleepMillis = (long) (Math.min(maxSleepMillis, baseSleepMillis * Math.pow(2, nTry - 1))
  7.                    * fuzzyMultiplier);
  8.   if (quiet) {
  9.    log.debug(e, "Failed on try %d, retrying in %,dms.", nTry, sleepMillis);
  10.   } else {
  11.    log.warn(e, "Failed on try %d, retrying in %,dms.", nTry, sleepMillis);
  12.   }
  13.   Thread.sleep(sleepMillis);
  14.  }
  15. }

代码示例来源：origin: com.metamx/java-util

  1. public Map<String, Long> to(String key, Map<String, Long> curr)
  2. {
  3.  final Map<String, Long> prev = prevs.put(key, curr);
  4.  if (prev != null) {
  5.   return subtract(curr, prev);
  6.  }
  7.  else {
  8.   log.debug("No previous data for key[%s]", key);
  9.   return null;
  10.  }
  11. }

代码示例来源：origin: com.n3twork.druid/druid-server

  1. @Override
  2.  public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params)
  3.  {
  4.   // Display info about all available segments
  5.   final Set<DataSegment> availableSegments = coordinator.getAvailableDataSegments();
  6.   if (log.isDebugEnabled()) {
  7.    log.debug("Available DataSegments");
  8.    for (DataSegment dataSegment : availableSegments) {
  9.     log.debug("  %s", dataSegment);
  10.    }
  11.   }
  13.   return params.buildFromExisting()
  14.          .withAvailableSegments(availableSegments)
  15.          .build();
  16.  }
  17. }

代码示例来源：origin: com.n3twork.druid/druid-server

  1. log.info("Loading properties from %s", propertiesFile);
  2.  try {
  3.   fileProps.load(new InputStreamReader(stream, Charsets.UTF_8));
  4. log.wtf(e, "This can only happen if the .exists() call lied.  That's f'd up.");

代码示例来源：origin: metamx/java-util

  1. @Test
  2. public void testLogWithCrazyMessages()
  3. {
  4.  final String message = "this % might %d kill %*.s the %s parser";
  5.  final Logger log = new Logger(LoggerTest.class);
  6.  log.warn(message);
  7. }

代码示例来源：origin: metamx/java-util

  1. @Override
  2. public boolean isGood(ChannelFuture resource)
  3. {
  4.  Channel channel = resource.awaitUninterruptibly().getChannel();
  5.  boolean isSuccess = resource.isSuccess();
  6.  boolean isConnected = channel.isConnected();
  7.  boolean isOpen = channel.isOpen();
  8.  if (log.isTraceEnabled()) {
  9.   log.trace("isGood = isSucess[%s] && isConnected[%s] && isOpen[%s]", isSuccess, isConnected, isOpen);
  10.  }
  11.  return isSuccess && isConnected && isOpen;
  12. }

代码示例来源：origin: com.n3twork.druid/druid-server

  1. @LifecycleStop
  2. public void stop() throws IOException
  3. {
  4.  synchronized (lock) {
  5.   if (childrenCache == null) {
  6.    return;
  7.   }
  8.   // This close() call actually calls shutdownNow() on the executor registered with the Cache object...
  9.   childrenCache.close();
  10.   childrenCache = null;
  11.  }
  12.  for (String containerKey : Lists.newArrayList(containers.keySet())) {
  13.   final ContainerHolder containerHolder = containers.remove(containerKey);
  14.   if (containerHolder == null) {
  15.    log.wtf("!?  Got key[%s] from keySet() but it didn't have a value!?", containerKey);
  16.   } else {
  17.    // This close() call actually calls shutdownNow() on the executor registered with the Cache object...
  18.    containerHolder.getCache().close();
  19.   }
  20.  }
  21. }

代码示例来源：origin: com.metamx/java-util

  1. @Override
  2.  public boolean doMonitor(ServiceEmitter emitter)
  3.  {
  4.   log.info("I am watching...");
  5.   return true;
  6.  }
  7. }

代码示例来源：origin: metamx/java-util

  1. @Override
  2.  public void stop()
  3.  {
  4.   log.info("Stopping object[%s]", o);
  5.   try {
  6.    stopMethod.invoke(o);
  7.   }
  8.   catch (Exception e) {
  9.    log.error(e, "Unable to invoke stopMethod() on %s", o.getClass());
  10.   }
  11.  }
  12. }

代码示例来源：origin: io.druid.extensions/druid-rabbitmq

  1. @Override
  2.  public void shutdownCompleted(ShutdownSignalException cause)
  3.  {
  4.   log.warn(cause, "Channel closed!");
  5.  }
  6. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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