net.spy.memcached.compat.log.Logger.info()方法的使用及代码示例

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

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

Logger.info介绍

[英]Log a message at info level.
[中]在信息级别记录消息。

代码示例

代码示例来源:origin: apache/kylin

@Override
public MetricCollector getMetricCollector() {
  String enableMetrics = metricsConfig.get("memcached.enabled");
  if (enableMetrics().equals(MetricType.OFF) || enableMetrics == null
      || "false".equalsIgnoreCase(enableMetrics)) {
    getLogger().debug("Memcached metrics collection disabled.");
    return new NoopMetricCollector();
  } else {
    getLogger().info("Memcached metrics collection enabled (Profile " + enableMetrics() + ").");
    return new MemcachedMetrics();
  }
}

代码示例来源:origin: com.google.code.maven-play-plugin.spy/memcached

/**
 * Close a closeable.
 */
public static void close(Closeable closeable) {
  if (closeable != null) {
    try {
      closeable.close();
    } catch (Exception e) {
      logger.info("Unable to close %s", closeable, e);
    }
  }
}

代码示例来源:origin: naver/arcus-java-client

/**
 * Close a closeable.
 */
public static void close(Closeable closeable) {
 if (closeable != null) {
  try {
   closeable.close();
  } catch (Exception e) {
   logger.info("Unable to close %s", closeable, e);
  }
 }
}

代码示例来源:origin: com.google.code.maven-play-plugin.spy/spymemcached

/**
 * Close a closeable.
 */
public static void close(Closeable closeable) {
  if (closeable != null) {
    try {
      closeable.close();
    } catch (Exception e) {
      logger.info("Unable to close %s", closeable, e);
    }
  }
}

代码示例来源:origin: com.couchbase.client/couchbase-client

private void logCreation() {
 getLogger().info("AdaptiveThrottler instantiated with options "
  + "normal_stats_interval: " + this.normalStatsInterval
  + " high_stats_interval: " + this.highStatsInterval
  + " critical_stats_interval: " + this.criticalStatsInterval
  + " high_sleep: " + this.highSleep
  + " critical_sleep: " + this.criticalSleep
  + " - for node " + this.node);
}

代码示例来源:origin: naver/arcus-java-client

public void delete(String k) {
 try {
  cache.remove(k);
 } catch (Exception e) {
  logger.info("failed to remove the locally cached item : %s", e.getMessage());
 }
}

代码示例来源:origin: naver/arcus-java-client

public <T> boolean put(String k, Future<T> future, long timeout) {
 if (future == null) {
  return false;
 }
 try {
  T v = future.get(timeout, TimeUnit.MILLISECONDS);
  return put(k, v);
 } catch (Exception e) {
  logger.info("failed to put to the local cache : %s", e.getMessage());
  return false;
 }
}

代码示例来源:origin: com.couchbase.client/couchbase-client

@Override
public void cancelled() {
 LOGGER.info("View Operation " + op.getRequest().getRequestLine()
  + " got cancelled.");
 op.cancel();
}

代码示例来源:origin: com.amazonaws/elasticache-java-cluster-client

@Override
public void receivedStatus(OperationStatus val) {
 // If the status we found was null, we're done.
 if (val.getMessage().length() == 0) {
  done.set(true);
  node.authComplete();
  getLogger().info("Authenticated to " + node.getSocketAddress());
 } else {
  foundStatus.set(val);
 }
}

代码示例来源:origin: com.google.code.maven-play-plugin.spy/spymemcached

public void receivedStatus(OperationStatus val) {
  // If the status we found was null, we're done.
  if(val.getMessage().length() == 0) {
    done.set(true);
    node.authComplete();
    getLogger().info("Authenticated to "
        + node.getSocketAddress());
  } else {
    foundStatus.set(val);
  }
}

代码示例来源:origin: net.spy/spymemcached

@Override
public void receivedStatus(OperationStatus val) {
 // If the status we found was null, we're done.
 if (val.getMessage().length() == 0) {
  done.set(true);
  node.authComplete();
  getLogger().info("Authenticated to " + node.getSocketAddress());
 } else {
  foundStatus.set(val);
 }
}

代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached

public void receivedStatus(OperationStatus val) {
 // If the status we found was null, we're done.
 if (val.getMessage().length() == 0) {
  done.set(true);
  node.authComplete();
  getLogger().info("Authenticated to " + node.getSocketAddress());
 } else {
  foundStatus.set(val);
 }
}

代码示例来源:origin: com.couchbase.client/couchbase-client

@Override
 public void run() {
  try {
   ioReactor.execute(ioEventDispatch);
  } catch (InterruptedIOException ex) {
   getLogger().error("I/O reactor Interrupted", ex);
  } catch (IOException e) {
   getLogger().error("I/O error: " + e.getMessage(), e);
  }
  getLogger().info("I/O reactor terminated");
 }
}, "Couchbase View Thread");

代码示例来源:origin: naver/arcus-java-client

public int moveOperations(final MemcachedNode toNode) {
 BlockingQueue<Operation> allOp = getAllOperations();
 int opCount = allOp.size();
 if (opCount > 0) {
  toNode.addAllOpToInputQ(allOp);
  getLogger().info("Total %d operations have been moved to %s", opCount, toNode);
 }
 return opCount;
}
/* ENABLE_REPLICATION end */

代码示例来源:origin: org.apache.kylin/kylin-cache

@Override
public MetricCollector getMetricCollector() {
  String enableMetrics = metricsConfig.get("memcached.enabled");
  if (enableMetrics().equals(MetricType.OFF) || enableMetrics == null
      || "false".equalsIgnoreCase(enableMetrics)) {
    getLogger().debug("Memcached metrics collection disabled.");
    return new NoopMetricCollector();
  } else {
    getLogger().info("Memcached metrics collection enabled (Profile " + enableMetrics() + ").");
    return new MemcachedMetrics();
  }
}

代码示例来源:origin: net.spy/spymemcached

private boolean preparePending() {
 // Copy the input queue into the write queue.
 copyInputQueue();
 // Now check the ops
 Operation nextOp = getCurrentWriteOp();
 while (nextOp != null && nextOp.isCancelled()) {
  getLogger().info("Removing cancelled operation: %s", nextOp);
  removeCurrentWriteOp();
  nextOp = getCurrentWriteOp();
 }
 return nextOp != null;
}

代码示例来源:origin: com.google.code.maven-play-plugin.spy/memcached

private boolean preparePending() {
  // Copy the input queue into the write queue.
  copyInputQueue();
  // Now check the ops
  Operation nextOp=getCurrentWriteOp();
  while(nextOp != null && nextOp.isCancelled()) {
    getLogger().info("Removing cancelled operation: %s", nextOp);
    removeCurrentWriteOp();
    nextOp=getCurrentWriteOp();
  }
  return nextOp != null;
}

代码示例来源:origin: com.google.code.simple-spring-memcached/spymemcached

private boolean preparePending() {
 // Copy the input queue into the write queue.
 copyInputQueue();
 // Now check the ops
 Operation nextOp = getCurrentWriteOp();
 while (nextOp != null && nextOp.isCancelled()) {
  getLogger().info("Removing cancelled operation: %s", nextOp);
  removeCurrentWriteOp();
  nextOp = getCurrentWriteOp();
 }
 return nextOp != null;
}

代码示例来源:origin: com.amazonaws/elasticache-java-cluster-client

private boolean preparePending() {
 // Copy the input queue into the write queue.
 copyInputQueue();
 // Now check the ops
 Operation nextOp = getCurrentWriteOp();
 while (nextOp != null && nextOp.isCancelled()) {
  getLogger().info("Removing cancelled operation: %s", nextOp);
  removeCurrentWriteOp();
  nextOp = getCurrentWriteOp();
 }
 return nextOp != null;
}

代码示例来源:origin: com.google.code.maven-play-plugin.spy/spymemcached

private boolean preparePending() {
  // Copy the input queue into the write queue.
  copyInputQueue();
  // Now check the ops
  Operation nextOp=getCurrentWriteOp();
  while(nextOp != null && nextOp.isCancelled()) {
    getLogger().info("Removing cancelled operation: %s", nextOp);
    removeCurrentWriteOp();
    nextOp=getCurrentWriteOp();
  }
  return nextOp != null;
}

相关文章