com.metamx.common.logger.Logger.warn()方法的使用及代码示例

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

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

Logger.warn介绍

[英]Protect against assuming slf4j convention. use warn(Throwable t, String message, Object... formatArgs) instead
[中]防止采用slf4j公约。使用“warn(Throwable t,String message,Object…formatArgs)”代替

代码示例

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

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

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

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

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

  1. @Override
  2. public void stop()
  3. {
  4. try {
  5. server.stop();
  6. }
  7. catch (Exception e) {
  8. log.warn(e, "Unable to stop Jetty server.");
  9. }
  10. }
  11. }

代码示例来源:origin: com.metamx/http-client

  1. private long getReadTimeout(Duration requestReadTimeout)
  2. {
  3. final long timeout;
  4. if (requestReadTimeout != null) {
  5. timeout = requestReadTimeout.getMillis();
  6. } else if (defaultReadTimeout != null) {
  7. timeout = defaultReadTimeout.getMillis();
  8. } else {
  9. timeout = 0;
  10. }
  11. if (timeout > 0 && timer == null) {
  12. log.warn("Cannot time out requests without a timer! Disabling timeout for this request.");
  13. return 0;
  14. } else {
  15. return timeout;
  16. }
  17. }

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

  1. @Override
  2. public InputStream nextElement()
  3. {
  4. try {
  5. return queue.take();
  6. }
  7. catch (InterruptedException e) {
  8. log.warn(e, "Thread interrupted while taking from queue");
  9. Thread.currentThread().interrupt();
  10. throw Throwables.propagate(e);
  11. }
  12. }
  13. }

代码示例来源:origin: com.metamx/http-client

  1. @Override
  2. public InputStream nextElement()
  3. {
  4. try {
  5. return queue.take();
  6. }
  7. catch (InterruptedException e) {
  8. log.warn(e, "Thread interrupted while taking from queue");
  9. Thread.currentThread().interrupt();
  10. throw Throwables.propagate(e);
  11. }
  12. }
  13. }

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

  1. @Override
  2. public InputStream nextElement()
  3. {
  4. try {
  5. return queue.take();
  6. }
  7. catch (InterruptedException e) {
  8. log.warn(e, "Thread interrupted while taking from queue");
  9. Thread.currentThread().interrupt();
  10. throw Throwables.propagate(e);
  11. }
  12. }
  13. }

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

  1. @Override
  2. public void returnResource()
  3. {
  4. if (returned.getAndSet(true)) {
  5. log.warn(String.format("Resource at key[%s] was returned multiple times?", key));
  6. } else {
  7. holder.giveBack(value);
  8. }
  9. }

代码示例来源:origin: com.metamx/http-client

  1. @Override
  2. public void returnResource()
  3. {
  4. if (returned.getAndSet(true)) {
  5. log.warn(String.format("Resource at key[%s] was returned multiple times?", key));
  6. } else {
  7. holder.giveBack(value);
  8. }
  9. }

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

  1. @Override
  2. public void returnResource()
  3. {
  4. if (returned.getAndSet(true)) {
  5. log.warn(String.format("Resource at key[%s] was returned multiple times?", key));
  6. } else {
  7. holder.giveBack(value);
  8. }
  9. }

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

  1. @Override
  2. protected void finalize() throws Throwable
  3. {
  4. if (!returned.get()) {
  5. log.warn(
  6. String.format(
  7. "Resource[%s] at key[%s] was not returned before Container was finalized, potential resource leak.",
  8. value,
  9. key
  10. )
  11. );
  12. returnResource();
  13. }
  14. super.finalize();
  15. }
  16. };

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

  1. @Override
  2. protected void finalize() throws Throwable
  3. {
  4. if (!returned.get()) {
  5. log.warn(
  6. String.format(
  7. "Resource[%s] at key[%s] was not returned before Container was finalized, potential resource leak.",
  8. value,
  9. key
  10. )
  11. );
  12. returnResource();
  13. }
  14. super.finalize();
  15. }
  16. };

代码示例来源:origin: 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. 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.n3twork.druid/druid-common

  1. private void poll()
  2. {
  3. for (Map.Entry<String, ConfigHolder> entry : watchedConfigs.entrySet()) {
  4. try {
  5. if (entry.getValue().swapIfNew(dbConnector.lookup(configTable, "name", "payload", entry.getKey()))) {
  6. log.info("New value for key[%s] seen.", entry.getKey());
  7. }
  8. }
  9. catch (Exception e) {
  10. log.warn(e, "Exception when checking property[%s]", entry.getKey());
  11. }
  12. }
  13. }

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

  1. private QueryableDruidServer addServer(DruidServer server)
  2. {
  3. QueryableDruidServer retVal = new QueryableDruidServer(server, makeDirectClient(server));
  4. QueryableDruidServer exists = clients.put(server.getName(), retVal);
  5. if (exists != null) {
  6. log.warn("QueryRunner for server[%s] already existed!? Well it's getting replaced", server);
  7. }
  8. return retVal;
  9. }

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

  1. @Override
  2. public void put(NamedKey key, byte[] value)
  3. {
  4. try {
  5. client.set(computeKeyHash(memcachedPrefix, key), expiration, serializeValue(key, value));
  6. } catch(IllegalStateException e) {
  7. // operation did not get queued in time (queue is full)
  8. errorCount.incrementAndGet();
  9. log.warn(e, "Unable to queue cache operation");
  10. }
  11. }

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

  1. public void unannounceTask(String taskId)
  2. {
  3. try {
  4. curatorFramework.delete().guaranteed().forPath(getTaskPathForId(taskId));
  5. }
  6. catch (Exception e) {
  7. log.warn(e, "Could not delete task path for task[%s]", taskId);
  8. }
  9. }

代码示例来源: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. @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. }

相关文章