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

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

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

Logger.fatal介绍

暂无

代码示例

代码示例来源:origin: io.vertx/vertx-lang-scala

  1. public void fatal(String message) {
  2. log.fatal(message);
  3. }

代码示例来源:origin: io.vertx/vertx-lang-scala

  1. public void fatal(String message, Throwable t) {
  2. log.fatal(message, t);
  3. }

代码示例来源:origin: io.vertx/vertx-lang-scala_2.12

  1. public void fatal(String message) {
  2. log.fatal(message);
  3. }

代码示例来源:origin: io.vertx/vertx-lang-scala_2.12

  1. public void fatal(String message, Throwable t) {
  2. log.fatal(message, t);
  3. }

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

  1. private String encode(String value) {
  2. try {
  3. return URLEncoder.encode(value, "UTF-8").replace("+", "%20").replace("%2F", "/");
  4. } catch (UnsupportedEncodingException ex) {
  5. LOGGER.fatal("Unexpected Exception - Unsupported encoding UTF-8", ex);
  6. throw new UnsupportedCharsetException("UTF-8");
  7. }
  8. }

代码示例来源:origin: io.knotx/knotx-databridge-adapter-http

  1. private static String encodeValue(String value) {
  2. try {
  3. return URLEncoder.encode(value, "UTF-8").replace("+", "%20").replace("%2F", "/");
  4. } catch (UnsupportedEncodingException ex) {
  5. LOGGER.fatal("Unexpected Exception - Unsupported encoding UTF-8", ex);
  6. throw new UnsupportedCharsetException("UTF-8");
  7. }
  8. }
  9. }

代码示例来源:origin: Cognifide/knotx

  1. private String encode(String value) {
  2. try {
  3. return URLEncoder.encode(value, "UTF-8").replace("+", "%20").replace("%2F", "/");
  4. } catch (UnsupportedEncodingException ex) {
  5. LOGGER.fatal("Unexpected Exception - Unsupported encoding UTF-8", ex);
  6. throw new UnsupportedCharsetException("UTF-8");
  7. }
  8. }

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

  1. @Override
  2. public void fatal(String msg) {
  3. logger.fatal(msg);
  4. }

代码示例来源:origin: Cognifide/knotx

  1. private static String encodeValue(String value) {
  2. try {
  3. return URLEncoder.encode(value, "UTF-8").replace("+", "%20").replace("%2F", "/");
  4. } catch (UnsupportedEncodingException ex) {
  5. LOGGER.fatal("Unexpected Exception - Unsupported encoding UTF-8", ex);
  6. throw new UnsupportedCharsetException("UTF-8");
  7. }
  8. }
  9. }

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

  1. @Override
  2. public void fatal(String msg, Throwable throwable) {
  3. logger.fatal(msg, throwable);
  4. }

代码示例来源:origin: pmlopes/yoke

  1. protected void logMessage(int status, String message)
  2. {
  3. if (status >= 500) {
  4. logger.fatal(message);
  5. } else if (status >= 400) {
  6. logger.error(message);
  7. } else if (status >= 300) {
  8. logger.warn(message);
  9. } else {
  10. logger.info(message);
  11. }
  12. }

代码示例来源:origin: folio-org/okapi

  1. private void startModmanager(Future<Void> fut) {
  2. moduleManager.init(vertx, res -> {
  3. if (res.succeeded()) {
  4. startTenants(fut);
  5. } else {
  6. logger.fatal("ModuleManager init: " + res.cause().getMessage());
  7. fut.fail(res.cause());
  8. }
  9. });
  10. }

代码示例来源:origin: folio-org/okapi

  1. private void startTenants(Future<Void> fut) {
  2. tenantManager.init(vertx, res -> {
  3. if (res.succeeded()) {
  4. checkInternalModules(fut);
  5. } else {
  6. logger.fatal("load tenants failed: " + res.cause().getMessage());
  7. fut.fail(res.cause());
  8. }
  9. });
  10. }

代码示例来源:origin: folio-org/okapi

  1. public void queryWithParams(String sql, JsonArray jsa,
  2. Handler<ExtendedAsyncResult<ResultSet>> fut) {
  3. getCon(gres -> {
  4. if (gres.failed()) {
  5. fut.handle(new Failure<>(gres.getType(), gres.cause()));
  6. } else {
  7. logger.debug("queryWithParams sql: " + sql);
  8. conn.queryWithParams(sql, jsa, qres -> {
  9. if (qres.failed()) {
  10. logger.fatal("queryWithParams failed: "
  11. + qres.cause() + " sql: " + sql);
  12. close();
  13. fut.handle(new Failure<>(INTERNAL, qres.cause()));
  14. } else {
  15. fut.handle(new Success<>(qres.result()));
  16. }
  17. });
  18. }
  19. });
  20. }

代码示例来源:origin: folio-org/okapi

  1. public void query(String sql,
  2. Handler<ExtendedAsyncResult<ResultSet>> fut) {
  3. getCon(gres -> {
  4. if (gres.failed()) {
  5. fut.handle(new Failure<>(gres.getType(), gres.cause()));
  6. } else {
  7. logger.debug("query sql: " + sql);
  8. conn.query(sql, qres -> {
  9. if (qres.failed()) {
  10. logger.fatal("query failed: "
  11. + qres.cause() + " sql: " + sql);
  12. close();
  13. fut.handle(new Failure<>(INTERNAL, qres.cause()));
  14. } else {
  15. fut.handle(new Success<>(qres.result()));
  16. }
  17. });
  18. }
  19. });
  20. }

代码示例来源:origin: apiman/apiman

  1. @Override
  2. public void start(Future<Void> start) {
  3. super.start(start);
  4. base = new DeploymentOptions().setConfig(config());
  5. @SuppressWarnings({ "rawtypes" }) // CompositeFuture doesn't accept generic type
  6. List<Future> deployList = new ArrayList<>();
  7. deploy(ApiVerticle.class.getCanonicalName(), ApiVerticle.VERTICLE_TYPE, deployList);
  8. deploy(HttpGatewayVerticle.class.getCanonicalName(), HttpGatewayVerticle.VERTICLE_TYPE, deployList);
  9. deploy(HttpsGatewayVerticle.class.getCanonicalName(), HttpsGatewayVerticle.VERTICLE_TYPE, deployList);
  10. CompositeFuture.all(deployList).setHandler(compositeResult -> {
  11. if (compositeResult.failed()) {
  12. compositeResult.cause().printStackTrace();
  13. log.fatal("Failed to deploy verticles: " + compositeResult.cause().getMessage());
  14. start.fail(compositeResult.cause());
  15. } else {
  16. log.info("Apiman Version: {0}", ApimanVersionCommand.getApimanVersion());
  17. if (log.isDebugEnabled()) log.debug("Git commit info: {0}", Version.get().getVerbose());
  18. log.info("Vert.x Version: {0}", VersionCommand.getVersion());
  19. log.info("Successfully deployed all verticles");
  20. log.info("Gateway API port: {0}", apimanConfig.getPort(ApiVerticle.VERTICLE_TYPE));
  21. start.complete();
  22. }
  23. });
  24. }

代码示例来源:origin: folio-org/okapi

  1. public void init(boolean reset, Handler<ExtendedAsyncResult<Void>> fut) {
  2. PostgresQuery q = pg.getQuery();
  3. if (!reset) {
  4. create(reset, q, fut);
  5. } else {
  6. String dropSql = "DROP TABLE IF EXISTS " + table;
  7. q.query(dropSql, (ExtendedAsyncResult<ResultSet> res) -> {
  8. if (res.failed()) {
  9. logger.fatal(dropSql + ": " + res.cause().getMessage());
  10. fut.handle(new Failure<>(res.getType(), res.cause()));
  11. } else {
  12. create(reset, q, fut);
  13. }
  14. });
  15. }
  16. }

代码示例来源:origin: folio-org/okapi

  1. @Override
  2. public void start(Future<Void> fut) {
  3. logger.debug("starting");
  4. if (storage != null) {
  5. storage.prepareDatabases(initMode, res -> {
  6. if (res.failed()) {
  7. logger.fatal("start failed", res.cause());
  8. fut.fail(res.cause());
  9. } else {
  10. if (initMode != NORMAL) {
  11. logger.info("Database operation " + initMode.toString() + " done. Exiting");
  12. System.exit(0);
  13. }
  14. startModmanager(fut);
  15. }
  16. });
  17. } else {
  18. startModmanager(fut);
  19. }
  20. }

代码示例来源:origin: io.knotx/knotx-databridge-core

  1. private Single<JsonObject> fetchServiceData(DataSourceEntry service, KnotContext request) {
  2. LOGGER.debug("Fetching data from service {} {}", service.getAddress(), service.getParams());
  3. try {
  4. return request.getCache()
  5. .get(service.getCacheKey(), () -> {
  6. LOGGER.debug("Requesting data from adapter {} with params {}", service.getAddress(),
  7. service.getParams());
  8. return serviceEngine.doServiceCall(service, request).cache();
  9. });
  10. } catch (ExecutionException e) {
  11. LOGGER.fatal("Unable to get service data {}", e);
  12. return Single.error(e);
  13. }
  14. }

代码示例来源:origin: Cognifide/knotx

  1. private Single<JsonObject> fetchServiceData(ServiceEntry service, KnotContext request) {
  2. LOGGER.debug("Fetching data from service {} {}", service.getAddress(), service.getParams());
  3. try {
  4. return request.getCache()
  5. .get(service.getCacheKey(), () -> {
  6. LOGGER.debug("Requesting data from adapter {} with params {}", service.getAddress(),
  7. service.getParams());
  8. return serviceEngine.doServiceCall(service, request).cache();
  9. });
  10. } catch (ExecutionException e) {
  11. LOGGER.fatal("Unable to get service data {}", e);
  12. return Single.error(e);
  13. }
  14. }

相关文章