io.vertx.core.logging.Logger.isDebugEnabled()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(209)

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

Logger.isDebugEnabled介绍

暂无

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

private static void logInternal(final String perms) {
 if (perms != null && log.isDebugEnabled()) {
  log.debug("You are running on Windows and POSIX style file permissions are not supported");
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 protected BlockingAction<Void> chownInternal(String path, String user, String group, Handler<AsyncResult<Void>> handler) {
  if (group != null && log.isDebugEnabled()) {
   log.debug("You are running on Windows and POSIX style file ownership is not supported");
  }
  return super.chownInternal(path, user, group, handler);
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
protected BlockingAction<Void> chmodInternal(String path, String perms, String dirPerms,
                       Handler<AsyncResult<Void>> handler) {
 Objects.requireNonNull(path);
 Objects.requireNonNull(perms);
 logInternal(perms);
 logInternal(dirPerms);
 if (log.isDebugEnabled()) {
  log.debug("You are running on Windows and POSIX style file permissions are not supported!");
 }
 return new BlockingAction<Void>(handler) {
  @Override
  public Void perform() {
   return null;
  }
 };
}

代码示例来源：origin: eclipse-vertx/vert.x

protected synchronized void handleException(Throwable t) {
 NetworkMetrics metrics = metrics();
 if (metrics != null) {
  metrics.exceptionOccurred(metric, remoteAddress(), t);
 }
 if (exceptionHandler != null) {
  exceptionHandler.handle(t);
 } else {
  if (log.isDebugEnabled()) {
   log.error(t.getMessage(), t);
  } else {
   log.error(t.getMessage());
  }
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

synchronized void writeMessage(ClusteredMessage message) {
 if (connected) {
  Buffer data = message.encodeToWire();
  if (metrics != null) {
   metrics.messageWritten(message.address(), data.length());
  }
  socket.write(data);
 } else {
  if (pending == null) {
   if (log.isDebugEnabled()) {
    log.debug("Not connected to server " + serverID + " - starting queuing");
   }
   pending = new ArrayDeque<>();
  }
  pending.add(message);
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

void close() {
 if (timeoutID != -1) {
  vertx.cancelTimer(timeoutID);
 }
 if (pingTimeoutID != -1) {
  vertx.cancelTimer(pingTimeoutID);
 }
 try {
  client.close();
 } catch (Exception ignore) {
 }
 // The holder can be null or different if the target server is restarted with same serverid
 // before the cleanup for the previous one has been processed
 if (eventBus.connections().remove(serverID, this)) {
  if (log.isDebugEnabled()) {
   log.debug("Cluster connection closed for server " + serverID);
  }
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

private synchronized void connected(NetSocket socket) {
 this.socket = socket;
 connected = true;
 socket.exceptionHandler(t -> close());
 socket.closeHandler(v -> close());
 socket.handler(data -> {
  // Got a pong back
  vertx.cancelTimer(timeoutID);
  schedulePing();
 });
 // Start a pinger
 schedulePing();
 if (pending != null) {
  if (log.isDebugEnabled()) {
   log.debug("Draining the queue for server " + serverID);
  }
  for (ClusteredMessage message : pending) {
   Buffer data = message.encodeToWire();
   if (metrics != null) {
    metrics.messageWritten(message.address(), data.length());
   }
   socket.write(data);
  }
 }
 pending = null;
}

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

private static void logInternal(final String perms) {
 if (perms != null && log.isDebugEnabled()) {
  log.debug("You are running on Windows and POSIX style file permissions are not supported");
 }
}

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

@Override
 protected BlockingAction<Void> chownInternal(String path, String user, String group, Handler<AsyncResult<Void>> handler) {
  if (group != null && log.isDebugEnabled()) {
   log.debug("You are running on Windows and POSIX style file ownership is not supported");
  }
  return super.chownInternal(path, user, group, handler);
 }
}

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

@Override
protected BlockingAction<Void> chmodInternal(String path, String perms, String dirPerms,
                       Handler<AsyncResult<Void>> handler) {
 Objects.requireNonNull(path);
 Objects.requireNonNull(perms);
 logInternal(perms);
 logInternal(dirPerms);
 if (log.isDebugEnabled()) {
  log.debug("You are running on Windows and POSIX style file permissions are not supported!");
 }
 return new BlockingAction<Void>(handler) {
  @Override
  public Void perform() {
   return null;
  }
 };
}

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

protected synchronized void handleException(Throwable t) {
 NetworkMetrics metrics = metrics();
 if (metrics != null) {
  metrics.exceptionOccurred(metric, remoteAddress(), t);
 }
 if (exceptionHandler != null) {
  exceptionHandler.handle(t);
 } else {
  if (log.isDebugEnabled()) {
   log.error(t.getMessage(), t);
  } else {
   log.error(t.getMessage());
  }
 }
}

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

synchronized void writeMessage(ClusteredMessage message) {
 if (connected) {
  Buffer data = message.encodeToWire();
  if (metrics != null) {
   metrics.messageWritten(message.address(), data.length());
  }
  socket.write(data);
 } else {
  if (pending == null) {
   if (log.isDebugEnabled()) {
    log.debug("Not connected to server " + serverID + " - starting queuing");
   }
   pending = new ArrayDeque<>();
  }
  pending.add(message);
 }
}

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

void close() {
 if (timeoutID != -1) {
  vertx.cancelTimer(timeoutID);
 }
 if (pingTimeoutID != -1) {
  vertx.cancelTimer(pingTimeoutID);
 }
 try {
  client.close();
 } catch (Exception ignore) {
 }
 // The holder can be null or different if the target server is restarted with same serverid
 // before the cleanup for the previous one has been processed
 if (eventBus.connections().remove(serverID, this)) {
  if (log.isDebugEnabled()) {
   log.debug("Cluster connection closed for server " + serverID);
  }
 }
}

代码示例来源：origin: vert-x3/vertx-web

private void internalHandleUnregister(SockJSSocket sock, JsonObject rawMsg, Map<String, MessageConsumer> registrations) {
 checkCallHook(() -> new BridgeEventImpl(BridgeEventType.UNREGISTER, rawMsg, sock),
  () -> {
   String address = rawMsg.getString("address");
   if (address == null) {
    replyError(sock, "missing_address");
    return;
   }
   Match match = checkMatches(false, address, null);
   if (match.doesMatch) {
    MessageConsumer reg = registrations.remove(address);
    if (reg != null) {
     reg.unregister();
     SockInfo info = sockInfos.get(sock);
     info.handlerCount--;
    }
   } else {
    if (log.isDebugEnabled()) {
     log.debug("Cannot unregister handler for address " + address + " because there is no inbound match");
    }
    replyError(sock, "access_denied");
   }
  }, () -> replyError(sock, "rejected"));
}

代码示例来源：origin: vert-x3/vertx-web

replyHandler = null;
if (log.isDebugEnabled()) {
 log.debug("Forwarding message to address " + address + " on event bus");

代码示例来源：origin: vert-x3/vertx-web

@Override
public void handle(RoutingContext context) {
  if (nagHttps && log.isDebugEnabled()) {
    String uri = context.request().absoluteURI();
    if (!uri.startsWith("https:")) {

代码示例来源：origin: vert-x3/vertx-web

return;
final boolean debug = log.isDebugEnabled();
if (debug) {
 log.debug("Received msg from client in bridge. address:" + address + " message:" + body);

代码示例来源：origin: vert-x3/vertx-web

final boolean debug = log.isDebugEnabled();
final String address = rawMsg.getString("address");
if (address == null) {

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

private synchronized void connected(NetSocket socket) {
 this.socket = socket;
 connected = true;
 socket.exceptionHandler(t -> close());
 socket.closeHandler(v -> close());
 socket.handler(data -> {
  // Got a pong back
  vertx.cancelTimer(timeoutID);
  schedulePing();
 });
 // Start a pinger
 schedulePing();
 if (pending != null) {
  if (log.isDebugEnabled()) {
   log.debug("Draining the queue for server " + serverID);
  }
  for (ClusteredMessage message : pending) {
   Buffer data = message.encodeToWire();
   if (metrics != null) {
    metrics.messageWritten(message.address(), data.length());
   }
   socket.write(data);
  }
 }
 pending = null;
}

代码示例来源：origin: gentics/mesh

@Override
public void removeEdgeType(String typeName) {
  if (log.isDebugEnabled()) {
    log.debug("Removing vertex type with name {" + typeName + "}");
  }
  OrientGraphNoTx noTx = txProvider.rawNoTx();
  try {
    noTx.dropEdgeType(typeName);
  } finally {
    noTx.shutdown();
  }
}

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

Logger

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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