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

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

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

Logger.error介绍

暂无

代码示例

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

  1. private void handleException(Throwable t) {
  2.  if (exceptionHandler != null && t instanceof Exception) {
  3.   exceptionHandler.handle(t);
  4.  } else {
  5.   log.error("Unhandled exception", t);
  6.  }
  7. }

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

  1. private <T> void reportResult(Context context, Handler<AsyncResult<T>> completionHandler, AsyncResult<T> result) {
  2.  context.runOnContext(v -> {
  3.   try {
  4.    completionHandler.handle(result);
  5.   } catch (Throwable t) {
  6.    log.error("Failure in calling handler", t);
  7.    throw t;
  8.   }
  9.  });
  10. }

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

  1. private void handleException(Exception e) {
  2.  handshaking = false;
  3.  buffered.clear();
  4.  Handler<Throwable> handler = exceptionHandler();
  5.  if (handler != null) {
  6.   context.executeFromIO(v -> {
  7.    handler.handle(e);
  8.   });
  9.  } else {
  10.   log.error("Error in websocket handshake", e);
  11.  }
  12. }

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

  1. private <T> void reportFailure(Throwable t, Context context, Handler<AsyncResult<T>> completionHandler) {
  2.  if (completionHandler != null) {
  3.   reportResult(context, completionHandler, Future.failedFuture(t));
  4.  } else {
  5.   log.error(t.getMessage(), t);
  6.  }
  7. }

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

  1. public void reportException(Throwable t) {
  2.  Handler<Throwable> handler = this.exceptionHandler;
  3.  if (handler == null) {
  4.   handler = owner.exceptionHandler();
  5.  }
  6.  if (handler != null) {
  7.   handler.handle(t);
  8.  } else {
  9.   log.error("Unhandled exception", t);
  10.  }
  11. }

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

  1. private void deployHADeployments() {
  2.  int size = toDeployOnQuorum.size();
  3.  if (size != 0) {
  4.   log.info("There are " + size + " HA deploymentIDs waiting on a quorum. These will now be deployed");
  5.   Runnable task;
  6.   while ((task = toDeployOnQuorum.poll()) != null) {
  7.    try {
  8.     task.run();
  9.    } catch (Throwable t) {
  10.     log.error("Failed to run redeployment task", t);
  11.    }
  12.   }
  13.  }
  14. }

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

  1. private void startEventBus(Handler<AsyncResult<Vertx>> resultHandler) {
  2.  eventBus.start(ar -> {
  3.   if (ar.succeeded()) {
  4.    initializeHaManager(resultHandler);
  5.   } else {
  6.    log.error("Failed to start event bus", ar.cause());
  7.    resultHandler.handle(Future.failedFuture(ar.cause()));
  8.   }
  9.  });
  10. }

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

  1. /**
  2.  * Creates a new instance of {@link VertxIsolatedDeployer}.
  3.  *
  4.  * @return the new instance.
  5.  */
  6. protected synchronized Object newInstance() {
  7.  try {
  8.   classloader = (classpath == null || classpath.isEmpty()) ?
  9.     ClasspathHandler.class.getClassLoader() : createClassloader();
  10.   Class<?> clazz = classloader.loadClass("io.vertx.core.impl.launcher.commands.VertxIsolatedDeployer");
  11.   return clazz.newInstance();
  12.  } catch (Exception e) {
  13.   log.error("Failed to load or instantiate the isolated deployer", e);
  14.   throw new IllegalStateException(e);
  15.  }
  16. }

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

  1. private void joinCluster(VertxOptions options, Handler<AsyncResult<Vertx>> resultHandler) {
  2.  clusterManager.setVertx(this);
  3.  clusterManager.join(ar -> {
  4.   if (ar.succeeded()) {
  5.    createHaManager(options, resultHandler);
  6.   } else {
  7.    log.error("Failed to join cluster", ar.cause());
  8.    resultHandler.handle(Future.failedFuture(ar.cause()));
  9.   }
  10.  });
  11. }

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

  1. private void closeClusterManager(Handler<AsyncResult<Void>> completionHandler) {
  2.  if (clusterManager != null) {
  3.   clusterManager.leave(ar -> {
  4.    if (ar.failed()) {
  5.     log.error("Failed to leave cluster", ar.cause());
  6.    }
  7.    if (completionHandler != null) {
  8.     runOnContext(v -> completionHandler.handle(Future.succeededFuture()));
  9.    }
  10.   });
  11.  } else if (completionHandler != null) {
  12.   runOnContext(v -> completionHandler.handle(Future.succeededFuture()));
  13.  }
  14. }

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

  1. /**
  2.  * Undeploys  the previously deployed verticle.
  3.  *
  4.  * @param completionHandler the completion handler
  5.  */
  6. public void undeploy(Handler<AsyncResult<Void>> completionHandler) {
  7.  vertx.undeploy(deploymentId, res -> {
  8.   if (res.failed()) {
  9.    log.error("Failed in undeploying " + deploymentId, res.cause());
  10.   } else {
  11.    log.info("Succeeded in undeploying " + deploymentId);
  12.   }
  13.   deploymentId = null;
  14.   completionHandler.handle(res);
  15.  });
  16. }

代码示例来源：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. @Override
  2. public String absoluteURI() {
  3.  if (absoluteURI == null) {
  4.   try {
  5.    absoluteURI = HttpUtils.absoluteURI(conn.getServerOrigin(), this);
  6.   } catch (URISyntaxException e) {
  7.    log.error("Failed to create abs uri", e);
  8.   }
  9.  }
  10.  return absoluteURI;
  11. }

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

  1. private void checkHADeployments() {
  2.  try {
  3.   if (attainedQuorum) {
  4.    deployHADeployments();
  5.   } else {
  6.    undeployHADeployments();
  7.   }
  8.  } catch (Throwable t) {
  9.   log.error("Failed when checking HA deploymentIDs", t);
  10.  }
  11. }

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

  1. public synchronized void setResult(AsyncResult<Void> result) {
  2.  this.result = result;
  3.  if (completionHandler != null) {
  4.   if (metrics != null && result.succeeded()) {
  5.    metric = metrics.handlerRegistered(address, repliedAddress);
  6.   }
  7.   Handler<AsyncResult<Void>> callback = completionHandler;
  8.   vertx.runOnContext(v -> callback.handle(result));
  9.  } else if (result.failed()) {
  10.   log.error("Failed to propagate registration for handler " + handler + " and address " + address);
  11.  } else if (metrics != null) {
  12.   metric = metrics.handlerRegistered(address, repliedAddress);
  13.  }
  14. }

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

  1. @Override
  2. public void next() {
  3.  if (iter.hasNext()) {
  4.   try {
  5.    Handler<DeliveryContext> handler = iter.next();
  6.    if (handler != null) {
  7.     handler.handle(this);
  8.    } else {
  9.     next();
  10.    }
  11.   } catch (Throwable t) {
  12.    log.error("Failure in interceptor", t);
  13.   }
  14.  } else {
  15.   holder.getHandler().handle(message);
  16.  }
  17. }

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

  1. @Override
  2. public String absoluteURI() {
  3.  if (method() == HttpMethod.CONNECT) {
  4.   return null;
  5.  }
  6.  synchronized (conn) {
  7.   if (absoluteURI == null) {
  8.    try {
  9.     absoluteURI = HttpUtils.absoluteURI(serverOrigin, this);
  10.    } catch (URISyntaxException e) {
  11.     log.error("Failed to create abs uri", e);
  12.    }
  13.   }
  14.   return absoluteURI;
  15.  }
  16. }

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

  1. private void createHaManager(VertxOptions options, Handler<AsyncResult<Vertx>> resultHandler) {
  2.  this.<Map<String, String>>executeBlocking(fut -> {
  3.   fut.complete(clusterManager.getSyncMap(CLUSTER_MAP_NAME));
  4.  }, false, ar -> {
  5.   if (ar.succeeded()) {
  6.    Map<String, String> clusterMap = ar.result();
  7.    haManager = new HAManager(this, deploymentManager, clusterManager, clusterMap, options.getQuorumSize(), options.getHAGroup(), options.isHAEnabled());
  8.    startEventBus(resultHandler);
  9.   } else {
  10.    log.error("Failed to start HAManager", ar.cause());
  11.    resultHandler.handle(Future.failedFuture(ar.cause()));
  12.   }
  13.  });
  14. }

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

  1. protected void closeClustered(List<Vertx> clustered) throws Exception {
  2.  CountDownLatch latch = new CountDownLatch(clustered.size());
  3.  for (Vertx clusteredVertx : clustered) {
  4.   clusteredVertx.close(ar -> {
  5.    if (ar.failed()) {
  6.     log.error("Failed to shutdown vert.x", ar.cause());
  7.    }
  8.    latch.countDown();
  9.   });
  10.  }
  11.  assertTrue(latch.await(180, TimeUnit.SECONDS));
  12. }

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

  1. private <T> void onSubsReceived(AsyncResult<ChoosableIterable<ClusterNodeInfo>> asyncResult, OutboundDeliveryContext<T> sendContext) {
  2.  if (asyncResult.succeeded()) {
  3.   ChoosableIterable<ClusterNodeInfo> serverIDs = asyncResult.result();
  4.   if (serverIDs != null && !serverIDs.isEmpty()) {
  5.    sendToSubs(serverIDs, sendContext);
  6.   } else {
  7.    if (metrics != null) {
  8.     metrics.messageSent(sendContext.message.address(), !sendContext.message.isSend(), true, false);
  9.    }
  10.    deliverMessageLocally(sendContext);
  11.   }
  12.  } else {
  13.   log.error("Failed to send message", asyncResult.cause());
  14.  }
  15. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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