org.vertx.java.core.logging.Logger.debug()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(272)

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

Logger.debug介绍

暂无

代码示例

代码示例来源:origin: org.vert-x/vertx-core

  1. public void handle(final Message<JsonObject> msg) {
  2. Match curMatch = checkMatches(false, address, msg.body);
  3. if (curMatch.doesMatch) {
  4. if (curMatch.requiresAuth && sockAuths.get(sock) == null) {
  5. log.debug("Outbound message for address " + address + " rejected because auth is required and socket is not authed");
  6. } else {
  7. checkAddAccceptedReplyAddress(msg.replyAddress);
  8. deliverMessage(sock, address, msg);
  9. }
  10. } else {
  11. log.debug("Outbound message for address " + address + " rejected because there is no inbound match");
  12. }
  13. }
  14. };

代码示例来源:origin: org.vert-x/vertx-core

  1. private 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: com.englishtown/vertx-mod-cassandra

  1. @Override
  2. protected void initLoadBalancingPolicy(JsonObject loadBalancing) {
  3. // Recall super
  4. super.initLoadBalancingPolicy(loadBalancing);
  5. // If LB policy not set, try env vars
  6. if (loadBalancingPolicy == null) {
  7. String localDC = container.env().get(ENV_VAR_LOCAL_DC);
  8. if (!Strings.isNullOrEmpty(localDC)) {
  9. logger.debug("Using environment config for Local DC of " + localDC);
  10. loadBalancingPolicy = new DCAwareRoundRobinPolicy(localDC);
  11. } else {
  12. logger.debug("No environment configuration found for local DC");
  13. }
  14. }
  15. }

代码示例来源:origin: com.englishtown/vertx-mod-cassandra

  1. @Override
  2. protected void initSeeds(JsonArray seeds) {
  3. // Recall super
  4. super.initSeeds(seeds);
  5. // If default, try env vars
  6. if (DEFAULT_SEEDS.equals(this.seeds)) {
  7. String envVarSeeds = container.env().get(ENV_VAR_SEEDS);
  8. if (!Strings.isNullOrEmpty(envVarSeeds)) {
  9. logger.debug("Using environment configuration of " + envVarSeeds);
  10. String[] seedsArray = envVarSeeds.split("\\|");
  11. this.seeds = ImmutableList.copyOf(seedsArray);
  12. }
  13. }
  14. }

代码示例来源:origin: org.vert-x/vertx-core

  1. public void handle(AsyncResult<Boolean> res) {
  2. if (res.succeeded()) {
  3. if (res.result) {
  4. cacheAuthorisation(sessionID, sock);
  5. checkAndSend(send, address, jsonObject, sock, replyAddress);
  6. } else {
  7. log.debug("Inbound message for address " + address + " rejected because sessionID is not authorised");
  8. }
  9. } else {
  10. log.error("Error in performing authorisation", res.exception);
  11. }
  12. }
  13. });

代码示例来源:origin: com.englishtown/vertx-mod-jersey

  1. @Override
  2. public void init(JerseyConfigurator configurator) {
  3. baseUri = configurator.getBaseUri();
  4. maxBodySize = configurator.getMaxBodySize();
  5. applicationHandlerDelegate = configurator.getApplicationHandler();
  6. logger.debug("DefaultJerseyHandler - initialized");
  7. }

代码示例来源:origin: com.englishtown/vertx-mod-cassandra

  1. /**
  2. * Reconnects to the cluster with a new session. Any existing session is closed asynchronously.
  3. */
  4. @Override
  5. public void reconnect() {
  6. logger.debug("Call to reconnect the session has been made");
  7. Session oldSession = session;
  8. session = cluster.connect();
  9. if (oldSession != null) {
  10. oldSession.closeAsync();
  11. }
  12. metrics.afterReconnect();
  13. }

代码示例来源:origin: com.englishtown/vertx-mod-cassandra

  1. @Override
  2. public void close() {
  3. logger.debug("Call to close the session has been made");
  4. if (metrics != null) {
  5. metrics.close();
  6. metrics = null;
  7. }
  8. if (cluster != null) {
  9. cluster.closeAsync().force();
  10. cluster = null;
  11. session = null;
  12. }
  13. clusterBuilder = null;
  14. }

代码示例来源:origin: org.vert-x/vertx-core

  1. private void doSendOrPub(final boolean send, final SockJSSocket sock, final String address,
  2. final JsonObject jsonObject, final String replyAddress) {
  3. if (log.isDebugEnabled()) {
  4. log.debug("Received msg from client in bridge. address:" + address + " message:" + jsonObject.encode());
  5. log.debug("Inbound message for address " + address + " rejected because it requires auth and sessionID is missing");
  6. log.debug("Inbound message for address " + address + " rejected because there is no match");

代码示例来源:origin: org.vert-x/vertx-core

  1. private void cleanupConnection(ServerID theServerID,
  2. ConnectionHolder holder,
  3. boolean failed) {
  4. if (holder.timeoutID != -1) {
  5. vertx.cancelTimer(holder.timeoutID);
  6. }
  7. if (holder.pingTimeoutID != -1) {
  8. vertx.cancelTimer(holder.pingTimeoutID);
  9. }
  10. try {
  11. holder.socket.close();
  12. } catch (Exception ignore) {
  13. }
  14. // The holder can be null or different if the target server is restarted with same serverid
  15. // before the cleanup for the previous one has been processed
  16. // So we only actually remove the entry if no new entry has been added
  17. if (connections.remove(theServerID, holder)) {
  18. log.debug("Cluster connection closed: " + theServerID + " holder " + holder);
  19. if (failed) {
  20. cleanSubsForServerID(theServerID);
  21. }
  22. }
  23. }

代码示例来源:origin: org.vert-x/vertx-core

  1. private void checkAndSend(boolean send, final String address, JsonObject jsonObject,
  2. final SockJSSocket sock,
  3. final String replyAddress) {
  4. final Handler<Message<JsonObject>> replyHandler;
  5. if (replyAddress != null) {
  6. replyHandler = new Handler<Message<JsonObject>>() {
  7. public void handle(Message<JsonObject> message) {
  8. // Note we don't check outbound matches for replies
  9. // Replies are always let through if the original message
  10. // was approved
  11. checkAddAccceptedReplyAddress(message.replyAddress);
  12. deliverMessage(sock, replyAddress, message);
  13. }
  14. };
  15. } else {
  16. replyHandler = null;
  17. }
  18. if (log.isDebugEnabled()) {
  19. log.debug("Forwarding message to address " + address + " on event bus");
  20. }
  21. if (send) {
  22. eb.send(address, jsonObject, replyHandler);
  23. } else {
  24. eb.publish(address, jsonObject);
  25. }
  26. }

代码示例来源:origin: org.vert-x/vertx-platform

  1. depName != null ? depName : "deployment-" + UUID.randomUUID().toString();
  2. log.debug("Deploying name : " + deploymentName + " main: " + main +
  3. " instances: " + instances);

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

  1. log.debug("Deploying name : " + deploymentID + " main: " + theMain + " instances: " + instances);

代码示例来源:origin: com.englishtown/vertx-mod-jersey

  1. logger.debug("DefaultJerseyHandler - handle request and read body: " + vertxRequest.method() + " " + vertxRequest.uri());
  2. logger.debug("DefaultJerseyHandler - handle request: " + vertxRequest.method() + " " + vertxRequest.uri());

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

  1. protected void sendRequest(String scheme, String host, int port, String uri, Handler<HttpClientResponse> respHandler) {
  2. final String proxyHost = getProxyHost();
  3. if (proxyHost != null) {
  4. // We use an absolute URI
  5. uri = scheme + "://" + host + ":" + port + uri;
  6. }
  7. HttpClientRequest req = client.get(uri, respHandler);
  8. if (proxyHost != null){
  9. if (isUseDestinationHostHeaderForProxy()) {
  10. req.putHeader("host", host);
  11. } else {
  12. req.putHeader("host", proxyHost);
  13. }
  14. } else {
  15. req.putHeader("host", host);
  16. }
  17. if (getBasicAuth() != null) {
  18. log.debug("Using HTTP Basic Authorization");
  19. req.putHeader("Authorization","Basic " + getBasicAuth());
  20. }
  21. req.putHeader("user-agent", "Vert.x Module Installer");
  22. req.end();
  23. }

相关文章