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

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

本文整理了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

  1. @Override
  2. public MetricCollector getMetricCollector() {
  3. String enableMetrics = metricsConfig.get("memcached.enabled");
  4. if (enableMetrics().equals(MetricType.OFF) || enableMetrics == null
  5. || "false".equalsIgnoreCase(enableMetrics)) {
  6. getLogger().debug("Memcached metrics collection disabled.");
  7. return new NoopMetricCollector();
  8. } else {
  9. getLogger().info("Memcached metrics collection enabled (Profile " + enableMetrics() + ").");
  10. return new MemcachedMetrics();
  11. }
  12. }

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

  1. /**
  2. * Close a closeable.
  3. */
  4. public static void close(Closeable closeable) {
  5. if (closeable != null) {
  6. try {
  7. closeable.close();
  8. } catch (Exception e) {
  9. logger.info("Unable to close %s", closeable, e);
  10. }
  11. }
  12. }

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

  1. /**
  2. * Close a closeable.
  3. */
  4. public static void close(Closeable closeable) {
  5. if (closeable != null) {
  6. try {
  7. closeable.close();
  8. } catch (Exception e) {
  9. logger.info("Unable to close %s", closeable, e);
  10. }
  11. }
  12. }

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

  1. /**
  2. * Close a closeable.
  3. */
  4. public static void close(Closeable closeable) {
  5. if (closeable != null) {
  6. try {
  7. closeable.close();
  8. } catch (Exception e) {
  9. logger.info("Unable to close %s", closeable, e);
  10. }
  11. }
  12. }

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

  1. private void logCreation() {
  2. getLogger().info("AdaptiveThrottler instantiated with options "
  3. + "normal_stats_interval: " + this.normalStatsInterval
  4. + " high_stats_interval: " + this.highStatsInterval
  5. + " critical_stats_interval: " + this.criticalStatsInterval
  6. + " high_sleep: " + this.highSleep
  7. + " critical_sleep: " + this.criticalSleep
  8. + " - for node " + this.node);
  9. }

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

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

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

  1. public <T> boolean put(String k, Future<T> future, long timeout) {
  2. if (future == null) {
  3. return false;
  4. }
  5. try {
  6. T v = future.get(timeout, TimeUnit.MILLISECONDS);
  7. return put(k, v);
  8. } catch (Exception e) {
  9. logger.info("failed to put to the local cache : %s", e.getMessage());
  10. return false;
  11. }
  12. }

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

  1. @Override
  2. public void cancelled() {
  3. LOGGER.info("View Operation " + op.getRequest().getRequestLine()
  4. + " got cancelled.");
  5. op.cancel();
  6. }

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

  1. @Override
  2. public void receivedStatus(OperationStatus val) {
  3. // If the status we found was null, we're done.
  4. if (val.getMessage().length() == 0) {
  5. done.set(true);
  6. node.authComplete();
  7. getLogger().info("Authenticated to " + node.getSocketAddress());
  8. } else {
  9. foundStatus.set(val);
  10. }
  11. }

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

  1. public void receivedStatus(OperationStatus val) {
  2. // If the status we found was null, we're done.
  3. if(val.getMessage().length() == 0) {
  4. done.set(true);
  5. node.authComplete();
  6. getLogger().info("Authenticated to "
  7. + node.getSocketAddress());
  8. } else {
  9. foundStatus.set(val);
  10. }
  11. }

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

  1. @Override
  2. public void receivedStatus(OperationStatus val) {
  3. // If the status we found was null, we're done.
  4. if (val.getMessage().length() == 0) {
  5. done.set(true);
  6. node.authComplete();
  7. getLogger().info("Authenticated to " + node.getSocketAddress());
  8. } else {
  9. foundStatus.set(val);
  10. }
  11. }

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

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

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

  1. @Override
  2. public void run() {
  3. try {
  4. ioReactor.execute(ioEventDispatch);
  5. } catch (InterruptedIOException ex) {
  6. getLogger().error("I/O reactor Interrupted", ex);
  7. } catch (IOException e) {
  8. getLogger().error("I/O error: " + e.getMessage(), e);
  9. }
  10. getLogger().info("I/O reactor terminated");
  11. }
  12. }, "Couchbase View Thread");

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

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

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

  1. @Override
  2. public MetricCollector getMetricCollector() {
  3. String enableMetrics = metricsConfig.get("memcached.enabled");
  4. if (enableMetrics().equals(MetricType.OFF) || enableMetrics == null
  5. || "false".equalsIgnoreCase(enableMetrics)) {
  6. getLogger().debug("Memcached metrics collection disabled.");
  7. return new NoopMetricCollector();
  8. } else {
  9. getLogger().info("Memcached metrics collection enabled (Profile " + enableMetrics() + ").");
  10. return new MemcachedMetrics();
  11. }
  12. }

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

  1. private boolean preparePending() {
  2. // Copy the input queue into the write queue.
  3. copyInputQueue();
  4. // Now check the ops
  5. Operation nextOp = getCurrentWriteOp();
  6. while (nextOp != null && nextOp.isCancelled()) {
  7. getLogger().info("Removing cancelled operation: %s", nextOp);
  8. removeCurrentWriteOp();
  9. nextOp = getCurrentWriteOp();
  10. }
  11. return nextOp != null;
  12. }

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

  1. private boolean preparePending() {
  2. // Copy the input queue into the write queue.
  3. copyInputQueue();
  4. // Now check the ops
  5. Operation nextOp=getCurrentWriteOp();
  6. while(nextOp != null && nextOp.isCancelled()) {
  7. getLogger().info("Removing cancelled operation: %s", nextOp);
  8. removeCurrentWriteOp();
  9. nextOp=getCurrentWriteOp();
  10. }
  11. return nextOp != null;
  12. }

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

  1. private boolean preparePending() {
  2. // Copy the input queue into the write queue.
  3. copyInputQueue();
  4. // Now check the ops
  5. Operation nextOp = getCurrentWriteOp();
  6. while (nextOp != null && nextOp.isCancelled()) {
  7. getLogger().info("Removing cancelled operation: %s", nextOp);
  8. removeCurrentWriteOp();
  9. nextOp = getCurrentWriteOp();
  10. }
  11. return nextOp != null;
  12. }

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

  1. private boolean preparePending() {
  2. // Copy the input queue into the write queue.
  3. copyInputQueue();
  4. // Now check the ops
  5. Operation nextOp = getCurrentWriteOp();
  6. while (nextOp != null && nextOp.isCancelled()) {
  7. getLogger().info("Removing cancelled operation: %s", nextOp);
  8. removeCurrentWriteOp();
  9. nextOp = getCurrentWriteOp();
  10. }
  11. return nextOp != null;
  12. }

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

  1. private boolean preparePending() {
  2. // Copy the input queue into the write queue.
  3. copyInputQueue();
  4. // Now check the ops
  5. Operation nextOp=getCurrentWriteOp();
  6. while(nextOp != null && nextOp.isCancelled()) {
  7. getLogger().info("Removing cancelled operation: %s", nextOp);
  8. removeCurrentWriteOp();
  9. nextOp=getCurrentWriteOp();
  10. }
  11. return nextOp != null;
  12. }

相关文章