本文整理了Java中net.spy.memcached.compat.log.Logger.info()
方法的一些代码示例,展示了Logger.info()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.info()
方法的具体详情如下:
包路径:net.spy.memcached.compat.log.Logger
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!