DATACASS-220 - Upgraded to Cassandra driver 2.1.6.

Adapted API change in TestLatencyTracker *sigh*. Removed version declaration for Guava to use the one from Spring Data Build.
This commit is contained in:
Oliver Gierke
2015-06-19 12:21:45 +02:00
parent 5ac374a5e9
commit 4acd159407
2 changed files with 13 additions and 10 deletions

View File

@@ -30,12 +30,10 @@
<dist.id>spring-data-cassandra</dist.id>
<springdata.commons>1.11.0.BUILD-SNAPSHOT</springdata.commons>
<cassandra-unit.version>2.0.2.2</cassandra-unit.version>
<cassandra-driver-dse>2.1.4</cassandra-driver-dse>
<el.version>1.0</el.version>
<failsafe.version>2.16</failsafe.version>
<jamm.version>0.2.5</jamm.version>
<cassandra>2.1.2</cassandra>
<guava>16.0.1</guava>
<cassandra>2.1.6</cassandra>
</properties>
<developers>
@@ -80,7 +78,7 @@
<dependency>
<groupId>com.datastax.cassandra</groupId>
<artifactId>cassandra-driver-dse</artifactId>
<version>${cassandra-driver-dse}</version>
<version>${cassandra}</version>
<exclusions>
<exclusion>
<artifactId>slf4j-log4j12</artifactId>

View File

@@ -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.");
}
}