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

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

本文整理了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

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

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

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

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

  1. @Override
  2. protected BlockingAction<Void> chmodInternal(String path, String perms, String dirPerms,
  3.                        Handler<AsyncResult<Void>> handler) {
  4.  Objects.requireNonNull(path);
  5.  Objects.requireNonNull(perms);
  6.  logInternal(perms);
  7.  logInternal(dirPerms);
  8.  if (log.isDebugEnabled()) {
  9.   log.debug("You are running on Windows and POSIX style file permissions are not supported!");
  10.  }
  11.  return new BlockingAction<Void>(handler) {
  12.   @Override
  13.   public Void perform() {
  14.    return null;
  15.   }
  16.  };
  17. }

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

  1. protected synchronized void handleException(Throwable t) {
  2.  NetworkMetrics metrics = metrics();
  3.  if (metrics != null) {
  4.   metrics.exceptionOccurred(metric, remoteAddress(), t);
  5.  }
  6.  if (exceptionHandler != null) {
  7.   exceptionHandler.handle(t);
  8.  } else {
  9.   if (log.isDebugEnabled()) {
  10.    log.error(t.getMessage(), t);
  11.   } else {
  12.    log.error(t.getMessage());
  13.   }
  14.  }
  15. }

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

  1. synchronized void writeMessage(ClusteredMessage message) {
  2.  if (connected) {
  3.   Buffer data = message.encodeToWire();
  4.   if (metrics != null) {
  5.    metrics.messageWritten(message.address(), data.length());
  6.   }
  7.   socket.write(data);
  8.  } else {
  9.   if (pending == null) {
  10.    if (log.isDebugEnabled()) {
  11.     log.debug("Not connected to server " + serverID + " - starting queuing");
  12.    }
  13.    pending = new ArrayDeque<>();
  14.   }
  15.   pending.add(message);
  16.  }
  17. }

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

  1. void close() {
  2.  if (timeoutID != -1) {
  3.   vertx.cancelTimer(timeoutID);
  4.  }
  5.  if (pingTimeoutID != -1) {
  6.   vertx.cancelTimer(pingTimeoutID);
  7.  }
  8.  try {
  9.   client.close();
  10.  } catch (Exception ignore) {
  11.  }
  12.  // The holder can be null or different if the target server is restarted with same serverid
  13.  // before the cleanup for the previous one has been processed
  14.  if (eventBus.connections().remove(serverID, this)) {
  15.   if (log.isDebugEnabled()) {
  16.    log.debug("Cluster connection closed for server " + serverID);
  17.   }
  18.  }
  19. }

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

  1. private synchronized void connected(NetSocket socket) {
  2.  this.socket = socket;
  3.  connected = true;
  4.  socket.exceptionHandler(t -> close());
  5.  socket.closeHandler(v -> close());
  6.  socket.handler(data -> {
  7.   // Got a pong back
  8.   vertx.cancelTimer(timeoutID);
  9.   schedulePing();
  10.  });
  11.  // Start a pinger
  12.  schedulePing();
  13.  if (pending != null) {
  14.   if (log.isDebugEnabled()) {
  15.    log.debug("Draining the queue for server " + serverID);
  16.   }
  17.   for (ClusteredMessage message : pending) {
  18.    Buffer data = message.encodeToWire();
  19.    if (metrics != null) {
  20.     metrics.messageWritten(message.address(), data.length());
  21.    }
  22.    socket.write(data);
  23.   }
  24.  }
  25.  pending = null;
  26. }

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

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

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

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

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

  1. @Override
  2. protected BlockingAction<Void> chmodInternal(String path, String perms, String dirPerms,
  3.                        Handler<AsyncResult<Void>> handler) {
  4.  Objects.requireNonNull(path);
  5.  Objects.requireNonNull(perms);
  6.  logInternal(perms);
  7.  logInternal(dirPerms);
  8.  if (log.isDebugEnabled()) {
  9.   log.debug("You are running on Windows and POSIX style file permissions are not supported!");
  10.  }
  11.  return new BlockingAction<Void>(handler) {
  12.   @Override
  13.   public Void perform() {
  14.    return null;
  15.   }
  16.  };
  17. }

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

  1. protected synchronized void handleException(Throwable t) {
  2.  NetworkMetrics metrics = metrics();
  3.  if (metrics != null) {
  4.   metrics.exceptionOccurred(metric, remoteAddress(), t);
  5.  }
  6.  if (exceptionHandler != null) {
  7.   exceptionHandler.handle(t);
  8.  } else {
  9.   if (log.isDebugEnabled()) {
  10.    log.error(t.getMessage(), t);
  11.   } else {
  12.    log.error(t.getMessage());
  13.   }
  14.  }
  15. }

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

  1. synchronized void writeMessage(ClusteredMessage message) {
  2.  if (connected) {
  3.   Buffer data = message.encodeToWire();
  4.   if (metrics != null) {
  5.    metrics.messageWritten(message.address(), data.length());
  6.   }
  7.   socket.write(data);
  8.  } else {
  9.   if (pending == null) {
  10.    if (log.isDebugEnabled()) {
  11.     log.debug("Not connected to server " + serverID + " - starting queuing");
  12.    }
  13.    pending = new ArrayDeque<>();
  14.   }
  15.   pending.add(message);
  16.  }
  17. }

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

  1. void close() {
  2.  if (timeoutID != -1) {
  3.   vertx.cancelTimer(timeoutID);
  4.  }
  5.  if (pingTimeoutID != -1) {
  6.   vertx.cancelTimer(pingTimeoutID);
  7.  }
  8.  try {
  9.   client.close();
  10.  } catch (Exception ignore) {
  11.  }
  12.  // The holder can be null or different if the target server is restarted with same serverid
  13.  // before the cleanup for the previous one has been processed
  14.  if (eventBus.connections().remove(serverID, this)) {
  15.   if (log.isDebugEnabled()) {
  16.    log.debug("Cluster connection closed for server " + serverID);
  17.   }
  18.  }
  19. }

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

  1. private void internalHandleUnregister(SockJSSocket sock, JsonObject rawMsg, Map<String, MessageConsumer> registrations) {
  2.  checkCallHook(() -> new BridgeEventImpl(BridgeEventType.UNREGISTER, rawMsg, sock),
  3.   () -> {
  4.    String address = rawMsg.getString("address");
  5.    if (address == null) {
  6.     replyError(sock, "missing_address");
  7.     return;
  8.    }
  9.    Match match = checkMatches(false, address, null);
  10.    if (match.doesMatch) {
  11.     MessageConsumer reg = registrations.remove(address);
  12.     if (reg != null) {
  13.      reg.unregister();
  14.      SockInfo info = sockInfos.get(sock);
  15.      info.handlerCount--;
  16.     }
  17.    } else {
  18.     if (log.isDebugEnabled()) {
  19.      log.debug("Cannot unregister handler for address " + address + " because there is no inbound match");
  20.     }
  21.     replyError(sock, "access_denied");
  22.    }
  23.   }, () -> replyError(sock, "rejected"));
  24. }

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

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

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

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

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

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

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

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

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

  1. private synchronized void connected(NetSocket socket) {
  2.  this.socket = socket;
  3.  connected = true;
  4.  socket.exceptionHandler(t -> close());
  5.  socket.closeHandler(v -> close());
  6.  socket.handler(data -> {
  7.   // Got a pong back
  8.   vertx.cancelTimer(timeoutID);
  9.   schedulePing();
  10.  });
  11.  // Start a pinger
  12.  schedulePing();
  13.  if (pending != null) {
  14.   if (log.isDebugEnabled()) {
  15.    log.debug("Draining the queue for server " + serverID);
  16.   }
  17.   for (ClusteredMessage message : pending) {
  18.    Buffer data = message.encodeToWire();
  19.    if (metrics != null) {
  20.     metrics.messageWritten(message.address(), data.length());
  21.    }
  22.    socket.write(data);
  23.   }
  24.  }
  25.  pending = null;
  26. }

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

  1. @Override
  2. public void removeEdgeType(String typeName) {
  3.   if (log.isDebugEnabled()) {
  4.     log.debug("Removing vertex type with name {" + typeName + "}");
  5.   }
  6.   OrientGraphNoTx noTx = txProvider.rawNoTx();
  7.   try {
  8.     noTx.dropEdgeType(typeName);
  9.   } finally {
  10.     noTx.shutdown();
  11.   }
  12. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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