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

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

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

Logger.warn介绍

暂无

代码示例

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

  1. @Override
  2.  public void run() {
  3.   logger.warn("hello");
  4.  }
  5. });

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

  1. private void reportBytesWritten(Object msg) {
  2.  if (metrics != null) {
  3.   long bytes = getBytes(msg);
  4.   if (bytes == -1) {
  5.    log.warn("Metrics could not be updated to include bytes written because of unknown object " + msg.getClass() + " being written.");
  6.   } else {
  7.    bytesWritten += bytes;
  8.   }
  9.  }
  10. }

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

  1. private void setClusterViewChangedHandler(HAManager haManager) {
  2.  haManager.setClusterViewChangedHandler(members -> {
  3.   ownSubs.forEach(address -> {
  4.    subs.add(address, nodeInfo, addResult -> {
  5.     if (addResult.failed()) {
  6.      log.warn("Failed to update subs map with self", addResult.cause());
  7.     }
  8.    });
  9.   });
  10.   subs.removeAllMatching((Serializable & Predicate<ClusterNodeInfo>) ci -> !members.contains(ci.nodeId), removeResult -> {
  11.    if (removeResult.failed()) {
  12.     log.warn("Error removing subs", removeResult.cause());
  13.    }
  14.   });
  15.  });
  16. }

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

  1. synchronized void connect() {
  2.  if (connected) {
  3.   throw new IllegalStateException("Already connected");
  4.  }
  5.  client.connect(serverID.port, serverID.host, res -> {
  6.   if (res.succeeded()) {
  7.    connected(res.result());
  8.   } else {
  9.    log.warn("Connecting to server " + serverID + " failed", res.cause());
  10.    close();
  11.   }
  12.  });
  13. }

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

  1. @Override
  2. public void handle(Message<T> message) {
  3.  Handler<Message<T>> theHandler;
  4.  ContextInternal ctx;
  5.  synchronized (this) {
  6.   if (demand == 0L) {
  7.    if (pending.size() < maxBufferedMessages) {
  8.     pending.add(message);
  9.    } else {
  10.     if (discardHandler != null) {
  11.      discardHandler.handle(message);
  12.     } else {
  13.      log.warn("Discarding message as more than " + maxBufferedMessages + " buffered in paused consumer. address: " + address);
  14.     }
  15.    }
  16.    return;
  17.   } else {
  18.    if (pending.size() > 0) {
  19.     pending.add(message);
  20.     message = pending.poll();
  21.    }
  22.    if (demand != Long.MAX_VALUE) {
  23.     demand--;
  24.    }
  25.    theHandler = handler;
  26.   }
  27.   ctx = handlerContext;
  28.  }
  29.  deliver(theHandler, message, ctx);
  30. }

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

  1. Method setter = getSetter(fieldName, options.getClass());
  2. if (setter == null) {
  3.  log.warn("No such property to configure on options: " + options.getClass().getName() + "." + fieldName);
  4.  continue;
  5.   arg = Enum.valueOf((Class<? extends Enum>)argType, propVal);
  6.  } else {
  7.   log.warn("Invalid type for setter: " + argType);
  8.   continue;
  9.  log.warn("Invalid argtype:" + argType + " on options: " + options.getClass().getName() + "." + fieldName);
  10.  continue;

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

  1. LOGGER.warn("A change in " + file.getAbsolutePath() + " has been detected, but the file does not belong to a " +
  2.   "watched roots: " + roots);
  3. return false;

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

  1. protected ContextImpl(VertxInternal vertx, EventLoop eventLoop, WorkerPool internalBlockingPool, WorkerPool workerPool, String deploymentID, JsonObject config,
  2.            ClassLoader tccl) {
  3.  if (DISABLE_TCCL && tccl != ClassLoader.getSystemClassLoader()) {
  4.   log.warn("You have disabled TCCL checks but you have a custom TCCL to set.");
  5.  }
  6.  this.deploymentID = deploymentID;
  7.  this.config = config;
  8.  this.eventLoop = eventLoop;
  9.  this.tccl = tccl;
  10.  this.owner = vertx;
  11.  this.workerPool = workerPool;
  12.  this.internalBlockingPool = internalBlockingPool;
  13.  this.orderedTasks = new TaskQueue();
  14.  this.internalOrderedTasks = new TaskQueue();
  15.  this.closeHooks = new CloseHooks(log);
  16. }

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

  1. protocols.retainAll(Arrays.asList(engine.getSupportedProtocols()));
  2. if (protocols.isEmpty()) {
  3.  log.warn("no SSL/TLS protocols are enabled due to configuration restrictions");

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

  1. private synchronized void checkQuorumWhenAdded(final String nodeID, final long start) {
  2.  if (clusterMap.containsKey(nodeID)) {
  3.   checkQuorum();
  4.   if (attainedQuorum) {
  5.    checkSubs(nodeID);
  6.   }
  7.  } else {
  8.   vertx.setTimer(200, tid -> {
  9.    // This can block on a monitor so it needs to run as a worker
  10.    vertx.executeBlockingInternal(fut -> {
  11.     if (System.currentTimeMillis() - start > 10000) {
  12.      log.warn("Timed out waiting for group information to appear");
  13.     } else if (!stopped) {
  14.      ContextInternal context = vertx.getContext();
  15.      try {
  16.       // Remove any context we have here (from the timer) otherwise will screw things up when verticles are deployed
  17.       ContextImpl.setContext(null);
  18.       checkQuorumWhenAdded(nodeID, start);
  19.      } finally {
  20.       ContextImpl.setContext((ContextImpl) context);
  21.      }
  22.     }
  23.     fut.complete();
  24.    }, null);
  25.   });
  26.  }
  27. }

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

  1. private VertxMetrics initialiseMetrics(VertxOptions options) {
  2.  if (options.getMetricsOptions() != null && options.getMetricsOptions().isEnabled()) {
  3.   VertxMetricsFactory factory = options.getMetricsOptions().getFactory();
  4.   if (factory == null) {
  5.    factory = ServiceHelper.loadFactoryOrNull(VertxMetricsFactory.class);
  6.    if (factory == null) {
  7.     log.warn("Metrics has been set to enabled but no VertxMetricsFactory found on classpath");
  8.    }
  9.   }
  10.   if (factory != null) {
  11.    VertxMetrics metrics = factory.metrics(options);
  12.    Objects.requireNonNull(metrics, "The metric instance created from " + factory + " cannot be null");
  13.    return metrics;
  14.   }
  15.  }
  16.  return null;
  17. }

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

  1. private void testWarning(Logger logger) {
  2.  String result = record(() -> logger.warn("hello"));
  3.  assertContains("[main] WARN my-slf4j-logger - hello", result);
  4.  result = record(() -> logger.warn("exception", new NullPointerException()));
  5.  assertTrue(result.contains("[main] WARN my-slf4j-logger - exception"));
  6.  assertTrue(result.contains("java.lang.NullPointerException"));
  7.  result = record(() -> logger.warn("hello {} and {}", "Paulo", "Julien"));
  8.  assertContains("[main] WARN my-slf4j-logger - hello Paulo and Julien", result);
  9.  result = record(() -> logger.warn("hello {}", "vert.x"));
  10.  assertContains("[main] WARN my-slf4j-logger - hello vert.x", result);
  11.  result = record(() -> logger.warn("hello {} - {}", "vert.x"));
  12.  assertContains("[main] WARN my-slf4j-logger - hello vert.x - {}", result);
  13.  result = record(() -> logger.warn("hello {}", "vert.x", "foo"));
  14.  assertContains("[main] WARN my-slf4j-logger - hello vert.x", result);
  15.  result = record(() -> logger.warn("{}, an exception has been thrown", new IllegalStateException(), "Luke"));
  16.  assertTrue(result.contains("[main] WARN my-slf4j-logger - Luke, an exception has been thrown"));
  17.  assertTrue(result.contains("java.lang.IllegalStateException"));
  18.  result = record(() -> logger.warn("{}, an exception has been thrown", "Luke", new IllegalStateException()));
  19.  assertTrue(result.contains("[main] WARN my-slf4j-logger - Luke, an exception has been thrown"));
  20.  assertTrue(result.contains("java.lang.IllegalStateException"));
  21. }

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

  1. Logger logger = LoggerFactory.getLogger("my-log4j2-logger");
  2. String result = recording.execute(() -> {
  3.  logger.warn("hello");
  4. });
  5. assertTrue(result.contains("hello"));
  6. result = recording.execute(() -> {
  7.  logger.warn("exception", new NullPointerException());
  8. });
  9. assertTrue(result.contains("exception"));
  10.  logger.warn("hello {} and {}", "Paulo", "Julien");
  11. });
  12. assertTrue(result.contains("hello Paulo and Julien"));
  13.  logger.warn("hello {}", "vert.x");
  14. });
  15. assertTrue(result.contains("hello vert.x"));
  16.  logger.warn("hello {} - {}", "vert.x");
  17. });
  18. assertTrue(result.contains("hello vert.x - {}"));
  19.  logger.warn("hello {} {}", "vert.x", "foo");
  20. });
  21. String expected = "hello vert.x foo";
  22.  logger.warn("{}, an exception has been thrown", new IllegalStateException(), "Luke");
  23. });
  24. assertTrue(result.contains("Luke, an exception has been thrown"));

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

  1. private void schedulePing() {
  2.  EventBusOptions options = eventBus.options();
  3.  pingTimeoutID = vertx.setTimer(options.getClusterPingInterval(), id1 -> {
  4.   // If we don't get a pong back in time we close the connection
  5.   timeoutID = vertx.setTimer(options.getClusterPingReplyInterval(), id2 -> {
  6.    // Didn't get pong in time - consider connection dead
  7.    log.warn("No pong from server " + serverID + " - will consider it dead");
  8.    close();
  9.   });
  10.   ClusteredMessage pingMessage =
  11.    new ClusteredMessage<>(serverID, PING_ADDRESS, null, null, null, new PingMessageCodec(), true, eventBus);
  12.   Buffer data = pingMessage.encodeToWire();
  13.   socket.write(data);
  14.  });
  15. }

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

  1. /**
  2.  * test socks4a proxy for accessing arbitrary server port using an already resolved address.
  3.  */
  4. @Test
  5. public void testWithSocks4LocalResolver() throws Exception {
  6.  NetClientOptions clientOptions = new NetClientOptions()
  7.    .setProxyOptions(new ProxyOptions().setType(ProxyType.SOCKS4).setPort(11080));
  8.  NetClient client = vertx.createNetClient(clientOptions);
  9.  server.connectHandler(sock -> {
  10.  });
  11.  proxy = new Socks4Proxy(null).start(vertx);
  12.  server.listen(1234, "localhost", ar -> {
  13.   assertTrue(ar.succeeded());
  14.   client.connect(1234, "127.0.0.1", ar2 -> {
  15.    if (ar2.failed()) {
  16.     log.warn("failed", ar2.cause());
  17.    }
  18.    assertTrue(ar2.succeeded());
  19.    // make sure we have gone through the proxy
  20.    assertEquals("127.0.0.1:1234", proxy.getLastUri());
  21.    testComplete();
  22.   });
  23.  });
  24.  await();
  25. }

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

  1. /**
  2.  * test socks5 proxy for accessing arbitrary server port.
  3.  */
  4. @Test
  5. public void testWithSocks5Proxy() throws Exception {
  6.  NetClientOptions clientOptions = new NetClientOptions()
  7.    .setProxyOptions(new ProxyOptions().setType(ProxyType.SOCKS5).setPort(11080));
  8.  NetClient client = vertx.createNetClient(clientOptions);
  9.  server.connectHandler(sock -> {
  10.  });
  11.  proxy = new SocksProxy(null);
  12.  proxy.start(vertx);
  13.  server.listen(1234, "localhost", ar -> {
  14.   assertTrue(ar.succeeded());
  15.   client.connect(1234, "localhost", ar2 -> {
  16.    if (ar2.failed()) {
  17.     log.warn("failed", ar2.cause());
  18.    }
  19.    assertTrue(ar2.succeeded());
  20.    // make sure we have gone through the proxy
  21.    assertEquals("localhost:1234", proxy.getLastUri());
  22.    testComplete();
  23.   });
  24.  });
  25.  await();
  26. }

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

  1. /**
  2.  * test socks4a proxy for accessing arbitrary server port.
  3.  */
  4. @Test
  5. public void testWithSocks4aProxy() throws Exception {
  6.  NetClientOptions clientOptions = new NetClientOptions()
  7.    .setProxyOptions(new ProxyOptions().setType(ProxyType.SOCKS4).setPort(11080));
  8.  NetClient client = vertx.createNetClient(clientOptions);
  9.  server.connectHandler(sock -> {
  10.  });
  11.  proxy = new Socks4Proxy(null);
  12.  proxy.start(vertx);
  13.  server.listen(1234, "localhost", ar -> {
  14.   assertTrue(ar.succeeded());
  15.   client.connect(1234, "localhost", ar2 -> {
  16.    if (ar2.failed()) {
  17.     log.warn("failed", ar2.cause());
  18.    }
  19.    assertTrue(ar2.succeeded());
  20.    // make sure we have gone through the proxy
  21.    assertEquals("localhost:1234", proxy.getLastUri());
  22.    testComplete();
  23.   });
  24.  });
  25.  await();
  26. }

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

  1. /**
  2.  * test http connect proxy for accessing a arbitrary server port
  3.  * note that this may not work with a "real" proxy since there are usually access rules defined
  4.  * that limit the target host and ports (e.g. connecting to localhost or to port 25 may not be allowed)
  5.  */
  6. @Test
  7. public void testWithHttpConnectProxy() throws Exception {
  8.  NetClientOptions clientOptions = new NetClientOptions()
  9.    .setProxyOptions(new ProxyOptions().setType(ProxyType.HTTP).setPort(13128));
  10.  NetClient client = vertx.createNetClient(clientOptions);
  11.  server.connectHandler(sock -> {
  12.  });
  13.  proxy = new HttpProxy(null);
  14.  proxy.start(vertx);
  15.  server.listen(1234, "localhost", ar -> {
  16.   assertTrue(ar.succeeded());
  17.   client.connect(1234, "localhost", ar2 -> {
  18.    if (ar2.failed()) {
  19.     log.warn("failed", ar2.cause());
  20.    }
  21.    assertTrue(ar2.succeeded());
  22.    // make sure we have gone through the proxy
  23.    assertEquals("localhost:1234", proxy.getLastUri());
  24.    testComplete();
  25.   });
  26.  });
  27.  await();
  28. }

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

  1. /**
  2.  * test socks4a proxy for accessing arbitrary server port using username auth.
  3.  */
  4. @Test
  5. public void testWithSocks4aProxyAuth() throws Exception {
  6.  NetClientOptions clientOptions = new NetClientOptions()
  7.    .setProxyOptions(new ProxyOptions().setType(ProxyType.SOCKS4).setPort(11080)
  8.      .setUsername("username"));
  9.  NetClient client = vertx.createNetClient(clientOptions);
  10.  server.connectHandler(sock -> {
  11.  });
  12.  proxy = new Socks4Proxy("username");
  13.  proxy.start(vertx);
  14.  server.listen(1234, "localhost", ar -> {
  15.   assertTrue(ar.succeeded());
  16.   client.connect(1234, "localhost", ar2 -> {
  17.    if (ar2.failed()) {
  18.     log.warn("failed", ar2.cause());
  19.    }
  20.    assertTrue(ar2.succeeded());
  21.    // make sure we have gone through the proxy
  22.    assertEquals("localhost:1234", proxy.getLastUri());
  23.    testComplete();
  24.   });
  25.  });
  26.  await();
  27. }

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

  1. private VertxImpl(VertxOptions options, Transport transport) {
  2.   log.warn("You're already on a Vert.x context, are you sure you want to create a new Vertx instance?");

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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