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

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

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

Logger.info介绍

[英]Log a message at the INFO level.
[中]在信息级别记录消息。

代码示例

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

  1. @Override
  2. public void onComplete() {
  3.   log.info("fluxion complete");
  4. }

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

  1. public Consumer<Object> loggingConsumer() {
  2.     return m -> LOG.info("(int) msg={}", m);
  3.   }
  4. /*

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

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

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

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

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

  1. @Override
  2. public void onNext(String s) {
  3.   if (s.startsWith("GOODBYE")) {
  4.     log.info("This is the end");
  5.   }
  6.   subscription.request(1);
  7. }

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

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

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

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

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

  1. @Test
  2. public void formatNull() {
  3.   logger.info(null, null, null);
  4.   assertThat(errContent.size()).isZero();
  5.   assertThat(outContent.toString())
  6.       .isEqualTo("[ INFO] (" + Thread.currentThread().getName() + ") null\n");
  7. }

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

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

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

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

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

  1. @Test
  2. public void info2() throws Exception {
  3.   logger.info("with cause", CAUSE);
  4.   assertThat(errContent.size()).isZero();
  5.   assertThat(outContent.toString())
  6.       .startsWith("[ INFO] (" + 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. /**
  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. .doOnNext(v -> LOGGER.info(v.toString()))
  2. .doOnComplete(latch::countDown)
  3. .collectList();

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

  1. @Test
  2. public void sampleTest() throws Exception {
  3.   CountDownLatch latch = new CountDownLatch(1);
  4.   Disposable top10every1second =
  5.    Flux.fromIterable(PULP_SAMPLE)
  6.        .publishOn(asyncGroup)
  7.        .flatMap(samuelJackson ->
  8.       Flux
  9.        .fromArray(samuelJackson.split(" "))
  10.        .publishOn(asyncGroup)
  11.        .filter(w -> !w.trim().isEmpty())
  12.        .doOnNext(i -> simulateLatency())
  13.     )
  14.        .window(Duration.ofSeconds(2))
  15.        .flatMap(s -> s.groupBy(w -> w)
  16.               .flatMap(w -> w.count().map(c -> Tuples.of(w.key(), c)))
  17.               .collectSortedList((a, b) -> -a.getT2().compareTo(b.getT2()))
  18.               .flatMapMany(Flux::fromIterable)
  19.               .take(10)
  20.               .doAfterTerminate(() -> LOG.info("------------------------ window terminated" +
  21.              "----------------------"))
  22.     )
  23.        .subscribe(
  24.      entry -> LOG.info(entry.getT1() + ": " + entry.getT2()),
  25.      error -> LOG.error("", error),
  26.           latch::countDown
  27.     );
  28.   awaitLatch(top10every1second, latch);
  29. }

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

  1. /**
  2.  * Reset the {@link #onHandleError(BiConsumer)} hook to the default no-op behavior.
  3.  */
  4. public static void resetOnHandleError() {
  5.   log.info("Reset to default: onHandleError");
  6.   onHandleErrorHook = null;
  7. }

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

  1. /**
  2.  * Define a hook that is executed when a {@link Scheduler} has
  3.  * {@link #handleError(Throwable) handled an error}. Note that it is executed after
  4.  * the error has been passed to the thread uncaughtErrorHandler, which is not the
  5.  * case when a fatal error occurs (see {@link Exceptions#throwIfJvmFatal(Throwable)}).
  6.  *
  7.  * @param c the new hook to set.
  8.  */
  9. public static void onHandleError(BiConsumer<Thread, ? super Throwable> c) {
  10.   log.info("Hooking new: onHandleError");
  11.   onHandleErrorHook = Objects.requireNonNull(c, "onHandleError");
  12. }

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

  1. @Override
  2.   protected void doComplete(Future<?> future, Subscriber<? super Void> s) {
  3.     log.info("JOIN {}", multicastAddress);
  4.     super.doComplete(future, s);
  5.   }
  6. };

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

  1. void log() {
  2.     if (log.isInfoEnabled()) {
  3.       log.info(COMMON_LOG_FORMAT, address, user, zonedDateTime,
  4.           method, uri, protocol, status, (contentLength > -1 ? contentLength : MISSING), port, duration());
  5.     }
  6.   }
  7. }

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

  1. void log() {
  2.     if (log.isInfoEnabled()) {
  3.       log.info(COMMON_LOG_FORMAT, address, user, zonedDateTime,
  4.           method, uri, protocol, status, (contentLength > -1 ? contentLength : MISSING), port, duration());
  5.     }
  6.   }
  7. }

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

  1. public BlockingNettyContext(Mono<? extends NettyContext> contextAsync,
  2.     String description, Duration lifecycleTimeout) {
  3.   this.description = description;
  4.   this.lifecycleTimeout = lifecycleTimeout;
  5.   this.context = contextAsync
  6.       .timeout(lifecycleTimeout, Mono.error(new TimeoutException(description + " couldn't be started within " + lifecycleTimeout.toMillis() + "ms")))
  7.       .doOnNext(ctx -> LOG.info("Started {} on {}", description, ctx.address()))
  8.       .block();
  9. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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