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

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

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

Logger.isInfoEnabled介绍

[英]Is the logger instance enabled for the INFO level?
[中]是否为信息级别启用了记录器实例?

代码示例

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

@Override
public boolean isInfoEnabled() {
  return delegate.isInfoEnabled();
}

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

@Override
@Nullable
public Runnable onAfterTerminateCall() {
  if ((options & AFTER_TERMINATE) == AFTER_TERMINATE && (level != Level.INFO || log.isInfoEnabled())) {
    return () -> log(SignalType.AFTER_TERMINATE, "");
  }
  return null;
}

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

@Override
@Nullable
public Runnable onCancelCall() {
  if ((options & CANCEL) == CANCEL && (level != Level.INFO || log.isInfoEnabled())) {
    return () -> log(SignalType.CANCEL, "");
  }
  return null;
}

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

@Override
@Nullable
public LongConsumer onRequestCall() {
  if ((options & REQUEST) == REQUEST && (level != Level.INFO || log.isInfoEnabled())) {
    return n -> log(SignalType.REQUEST,
        Long.MAX_VALUE == n ? "unbounded" : n);
  }
  return null;
}

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

@Nullable
@Override
public Consumer<? super Context> onCurrentContextCall() {
  if ((options & CONTEXT_PARENT) == CONTEXT_PARENT && (level != Level.INFO || log
      .isInfoEnabled())) {
    return c -> log(SignalType.ON_CONTEXT, c);
  }
  return null;
}

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

@Override
@Nullable
public Consumer<? super IN> onNextCall() {
  if ((options & ON_NEXT) == ON_NEXT && (level != Level.INFO || log.isInfoEnabled())) {
    return d -> safeLog(SignalType.ON_NEXT, d);
  }
  return null;
}

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

@Override
@Nullable
public Runnable onCompleteCall() {
  if ((options & ON_COMPLETE) == ON_COMPLETE && (level != Level.INFO || log.isInfoEnabled())) {
    return () -> log(SignalType.ON_COMPLETE, "");
  }
  return null;
}

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

@Override
@Nullable
public Consumer<? super Subscription> onSubscribeCall() {
  if ((options & ON_SUBSCRIBE) == ON_SUBSCRIBE && (level != Level.INFO || log.isInfoEnabled())) {
    return s -> log(SignalType.ON_SUBSCRIBE, subscriptionAsString(s));
  }
  return null;
}

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

@Test
public void isInfoEnabled() throws Exception {
  assertThat(logger.isInfoEnabled()).isTrue();
}

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

@Override
  protected void doComplete(ChannelFuture future, Subscriber<? super Void> s) {
    if(log.isInfoEnabled()) {
      log.info("BIND {} {}",
          future.isSuccess() ? "OK" : "FAILED",
          future.channel()
             .localAddress());
    }
    if (listenAddress.getPort() == 0) {
      listenAddress = (InetSocketAddress) future.channel()
                           .localAddress();
    }
    super.doComplete(future, s);
  }
};

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

@Override
@Nullable
public Runnable onCompleteCall() {
  if ((options & ON_COMPLETE) == ON_COMPLETE && (level != Level.INFO || log.isInfoEnabled())) {
    return () -> log(SignalType.ON_COMPLETE, "");
  }
  return null;
}

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

@Nullable
@Override
public Consumer<? super Context> onCurrentContextCall() {
  if ((options & CONTEXT_PARENT) == CONTEXT_PARENT && (level != Level.INFO || log
      .isInfoEnabled())) {
    return c -> log(SignalType.ON_CONTEXT, c);
  }
  return null;
}

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

@Override
@Nullable
public Consumer<? super IN> onNextCall() {
  if ((options & ON_NEXT) == ON_NEXT && (level != Level.INFO || log.isInfoEnabled())) {
    return d -> safeLog(SignalType.ON_NEXT, d);
  }
  return null;
}

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

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

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

@Override
@Nullable
public Runnable onCancelCall() {
  if ((options & CANCEL) == CANCEL && (level != Level.INFO || log.isInfoEnabled())) {
    return () -> log(SignalType.CANCEL, "");
  }
  return null;
}

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

@Override
@Nullable
public Runnable onAfterTerminateCall() {
  if ((options & AFTER_TERMINATE) == AFTER_TERMINATE && (level != Level.INFO || log.isInfoEnabled())) {
    return () -> log(SignalType.AFTER_TERMINATE, "");
  }
  return null;
}

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

@Override
@Nullable
public LongConsumer onRequestCall() {
  if ((options & REQUEST) == REQUEST && (level != Level.INFO || log.isInfoEnabled())) {
    return n -> log(SignalType.REQUEST,
        Long.MAX_VALUE == n ? "unbounded" : n);
  }
  return null;
}

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

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

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

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

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

@Override
@Nullable
public Consumer<? super Subscription> onSubscribeCall() {
  if ((options & ON_SUBSCRIBE) == ON_SUBSCRIBE && (level != Level.INFO || log.isInfoEnabled())) {
    return s -> log(SignalType.ON_SUBSCRIBE, subscriptionAsString(s));
  }
  return null;
}

相关文章