reactor.util.Logger.warn()方法的使用及代码示例

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

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

Logger.warn介绍

[英]Log a message at the WARN level.
[中]

代码示例

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void warn(String msg) {
  3.   delegate.warn(msg);
  4. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void warn(String msg, Throwable t) {
  3.   delegate.warn(msg, t);
  4. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void onError(Throwable e) {
  3.   Loggers.getLogger(FluxUsingWhen.class).warn("Async resource cleanup failed after cancel", e);
  4. }

代码示例来源：origin: reactor/reactor-core

  1. /**
  2.  * Invoke a (local or global) hook that processes elements that get discarded en masse.
  3.  * This includes elements that are buffered but subsequently discarded due to
  4.  * cancellation or error.
  5.  *
  6.  * @param multiple the collection of elements to discard (possibly extracted from other
  7.  * collections/arrays/queues)
  8.  * @param context the {@link Context} in which to look for local hook
  9.  * @see #onDiscard(Object, Context)
  10.  * @see #onDiscardMultiple(Collection, Context)
  11.  * @see #onDiscardQueueWithClear(Queue, Context, Function)
  12.  */
  13. public static void onDiscardMultiple(Stream<?> multiple, Context context) {
  14.    Consumer<Object> hook = context.getOrDefault(Hooks.KEY_ON_DISCARD, null);
  15.    if (hook != null) {
  16.      try {
  17.        multiple.forEach(hook);
  18.      }
  19.      catch (Throwable t) {
  20.        log.warn("Error in discard hook while discarding multiple values", t);
  21.      }
  22.    }
  23.  }

代码示例来源：origin: reactor/reactor-core

  1. /**
  2.  * Invoke a (local or global) hook that processes elements that get discarded en masse.
  3.  * This includes elements that are buffered but subsequently discarded due to
  4.  * cancellation or error.
  5.  *
  6.  * @param multiple the collection of elements to discard
  7.  * @param context the {@link Context} in which to look for local hook
  8.  * @see #onDiscard(Object, Context)
  9.  * @see #onDiscardMultiple(Stream, Context)
  10.  * @see #onDiscardQueueWithClear(Queue, Context, Function)
  11.  */
  12.  public static void onDiscardMultiple(@Nullable Collection<?> multiple, Context context) {
  13.    if (multiple == null) return;
  14.    Consumer<Object> hook = context.getOrDefault(Hooks.KEY_ON_DISCARD, null);
  15.    if (hook != null) {
  16.      try {
  17.        multiple.forEach(hook);
  18.      }
  19.      catch (Throwable t) {
  20.        log.warn("Error in discard hook while discarding multiple values", t);
  21.      }
  22.    }
  23.  }

代码示例来源：origin: reactor/reactor-core

  1. /**
  2.  * Invoke a (local or global) hook that processes elements that get discarded. This
  3.  * includes elements that are dropped (for malformed sources), but also filtered out
  4.  * (eg. not passing a {@code filter()} predicate).
  5.  * <p>
  6.  * For elements that are buffered or enqueued, but subsequently discarded due to
  7.  * cancellation or error, see {@link #onDiscardMultiple(Stream, Context)} and
  8.  * {@link #onDiscardQueueWithClear(Queue, Context, Function)}.
  9.  *
  10.  * @param element the element that is being discarded
  11.  * @param context the context in which to look for a local hook
  12.  * @param <T> the type of the element
  13.  * @see #onDiscardMultiple(Stream, Context)
  14.  * @see #onDiscardMultiple(Collection, Context)
  15.  * @see #onDiscardQueueWithClear(Queue, Context, Function)
  16.  */
  17. public static <T> void onDiscard(@Nullable T element, Context context) {
  18.   Consumer<Object> hook = context.getOrDefault(Hooks.KEY_ON_DISCARD, null);
  19.   if (element != null && hook != null) {
  20.     try {
  21.       hook.accept(element);
  22.     }
  23.     catch (Throwable t) {
  24.       log.warn("Error in discard hook", t);
  25.     }
  26.   }
  27. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void warn(String format, Object... arguments) {
  3.   delegate.warn(format, wrapArguments(arguments));
  4. }

代码示例来源：origin: reactor/reactor-core

  1. log.warn("Error in discard hook while discarding and clearing a queue", t);

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void warn1() throws Exception {
  3.   logger.warn("message {} {} format", "with", 1);
  4.   assertThat(outContent.size()).isZero();
  5.   assertThat(errContent.toString()).isEqualTo("[ WARN] (" + Thread.currentThread().getName() + ") message with 1 format\n");
  6. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void warn() throws Exception {
  3.   logger.warn("message");
  4.   assertThat(outContent.size()).isZero();
  5.   assertThat(errContent.toString()).isEqualTo("[ WARN] (" + Thread.currentThread().getName() + ") message\n");
  6. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void warnNulls() {
  3.   logger.warn("vararg {} is {}", (Object[]) null);
  4.   logger.warn("param {} is {}", null, null);
  5.   assertThat(errContent.toString())
  6.       .contains("vararg {} is {}")
  7.       .contains("param null is null");
  8.   assertThat(outContent.size()).isZero();
  9. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void warn2() throws Exception {
  3.   logger.warn("with cause", CAUSE);
  4.   assertThat(outContent.size()).isZero();
  5.   assertThat(errContent.toString())
  6.       .startsWith("[ WARN] (" + Thread.currentThread().getName() + ") with cause - java.lang.IllegalStateException: cause" +
  7.           "\njava.lang.IllegalStateException: cause\n" +
  8.           "\tat reactor.util.ConsoleLoggerTest");
  9. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void monoLogWithGivenLogger() {
  3.   Level level = Level.WARNING;
  4.   Mono<String> source = Mono.just("foo");
  5.   Logger mockLogger = Mockito.mock(Logger.class);
  6.   source.log(mockLogger, level, false, SignalType.ON_NEXT)
  7.      .subscribe();
  8.   verify(mockLogger, only()).warn(anyString(), eq(SignalType.ON_NEXT),
  9.       eq("foo"));
  10.   verifyNoMoreInteractions(mockLogger);
  11. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void fluxLogWithGivenLogger() {
  3.   Level level = Level.WARNING;
  4.   Flux<String> source = Flux.just("foo");
  5.   Logger mockLogger = Mockito.mock(Logger.class);
  6.   source.log(mockLogger, level, false, SignalType.ON_NEXT)
  7.      .subscribe();
  8.   verify(mockLogger, only()).warn(anyString(), eq(SignalType.ON_NEXT),
  9.       eq("foo"));
  10.   verifyNoMoreInteractions(mockLogger);
  11. }

代码示例来源：origin: reactor/reactor-core

  1. @Override
  2. public void cancel() {
  3.   if (CALLBACK_APPLIED.compareAndSet(this, 0, 1)) {
  4.     if (Operators.terminate(SUBSCRIPTION, this)) {
  5.       try {
  6.         if (asyncCancel != null) {
  7.           Flux.from(asyncCancel.apply(resource))
  8.             .subscribe(new CancelInner(this));
  9.         }
  10.         else {
  11.           Flux.from(asyncComplete.apply(resource))
  12.             .subscribe(new CancelInner(this));
  13.         }
  14.       }
  15.       catch (Throwable error) {
  16.         Loggers.getLogger(FluxUsingWhen.class).warn("Error generating async resource cleanup during onCancel", error);
  17.       }
  18.     }
  19.   }
  20. }

代码示例来源：origin: reactor/reactor-core

  1. LOGGER.warn("Attempting to activate metrics but the upstream is not Scannable. " +
  2.     "You might want to use `name()` (and optionally `tags()`) right before `metrics()`");
  3. name = REACTOR_DEFAULT_NAME;

代码示例来源：origin: reactor/reactor-core

  1. /**
  2.  * Structured logging with level adaptation and operator ascii graph if required.
  3.  *
  4.  * @param signalType the type of signal being logged
  5.  * @param signalValue the value for the signal (use empty string if not required)
  6.  */
  7. void log(SignalType signalType, Object signalValue) {
  8.   String line = fuseable ? LOG_TEMPLATE_FUSEABLE : LOG_TEMPLATE;
  9.   if (operatorLine != null) {
  10.     line = line + " " + operatorLine;
  11.   }
  12.   if (level == Level.FINEST) {
  13.     log.trace(line, signalType, signalValue);
  14.   }
  15.   else if (level == Level.FINE) {
  16.     log.debug(line, signalType, signalValue);
  17.   }
  18.   else if (level == Level.INFO) {
  19.     log.info(line, signalType, signalValue);
  20.   }
  21.   else if (level == Level.WARNING) {
  22.     log.warn(line, signalType, signalValue);
  23.   }
  24.   else if (level == Level.SEVERE) {
  25.     log.error(line, signalType, signalValue);
  26.   }
  27. }

代码示例来源：origin: reactor/reactor-core

  1. private void demonstrateLogError() {
  2.   Loggers.getLogger("logError.default")
  3.       .warn("The following logs should demonstrate similar error output, but respectively at ERROR, DEBUG and TRACE levels");
  4.   Mono<Object> error = Mono.error(new IllegalStateException("boom"));
  5.   error.log("logError.default")
  6.      .subscribe(v -> {}, e -> {});
  7.   error.log("logError.fine", Level.FINE)
  8.      .subscribe(v -> {}, e -> {});
  9.   error.log("logError.finest", Level.FINEST)
  10.      .subscribe(v -> {}, e -> {});
  11. }

代码示例来源：origin: io.projectreactor/reactor-core

  1. @Override
  2. public void onError(Throwable e) {
  3.   Loggers.getLogger(FluxUsingWhen.class).warn("Async resource cleanup failed after cancel", e);
  4. }

代码示例来源：origin: reactor/reactor-netty

  1. @Override
  2. public void onUncaughtException(Connection connection, Throwable error) {
  3.   if (error instanceof RedirectClientException && log.isDebugEnabled()) {
  4.     log.debug(format(connection.channel(), "The request will be redirected"));
  5.   }
  6.   else if (AbortedException.isConnectionReset(error) && log.isDebugEnabled()) {
  7.     log.debug(format(connection.channel(), "The connection observed an error, " +
  8.         "the request will be retried"), error);
  9.   }
  10.   else {
  11.     log.warn(format(connection.channel(), "The connection observed an error"), error);
  12.   }
  13.   sink.error(error);
  14. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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