DATACASS-220 - Upgraded to Cassandra driver 2.1.6.
Adapted API change in TestLatencyTracker *sigh*.
This commit is contained in:
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2013-2014 the original author or authors.
|
||||
* Copyright 2013-2015 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -20,17 +20,22 @@ import org.slf4j.LoggerFactory;
|
||||
|
||||
import com.datastax.driver.core.Host;
|
||||
import com.datastax.driver.core.LatencyTracker;
|
||||
import com.datastax.driver.core.Statement;
|
||||
|
||||
/**
|
||||
* @author David Webb
|
||||
* @author Oliver Gierke
|
||||
*/
|
||||
public class TestLatencyTracker implements LatencyTracker {
|
||||
|
||||
private final static Logger log = LoggerFactory.getLogger(TestLatencyTracker.class);
|
||||
|
||||
private final static Logger LOG = LoggerFactory.getLogger(TestLatencyTracker.class);
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see com.datastax.driver.core.LatencyTracker#update(com.datastax.driver.core.Host, com.datastax.driver.core.Statement, java.lang.Exception, long)
|
||||
*/
|
||||
@Override
|
||||
public void update(Host host, long newLatencyNanos) {
|
||||
log.info("Latency Tracker: " + host.getAddress() + ", " + newLatencyNanos + " nanoseconds.");
|
||||
public void update(Host host, Statement statement, Exception exception, long newLatencyNanos) {
|
||||
LOG.info("Latency Tracker: " + host.getAddress() + ", " + newLatencyNanos + " nanoseconds.");
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user