本文整理了Java中reactor.util.Logger.isInfoEnabled()
方法的一些代码示例,展示了Logger.isInfoEnabled()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.isInfoEnabled()
方法的具体详情如下:
包路径:reactor.util.Logger
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!