Skip to content
This repository has been archived by the owner on Feb 27, 2023. It is now read-only.

Commit

Permalink
updated version in pom, added fix for CCP
Browse files Browse the repository at this point in the history
  • Loading branch information
zznate committed Sep 28, 2010
1 parent 0556ecc commit b8d289e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Expand Up @@ -5,7 +5,7 @@
<artifactId>hector</artifactId>
<packaging>bundle</packaging>
<!-- The version follows Cassandra's major version changes, e.g. 0.5.1 goes with the 0.5.1 cassandra release-->
<version>0.6.0-16</version>
<version>0.6.0-17</version>
<name>hector</name>
<description>Cassandra Java Client Library</description>
<url>http://github.com/rantav/hector</url>
Expand Down
Expand Up @@ -38,7 +38,7 @@
private final CassandraClientMonitor clientMonitor;

private CassandraHostConfigurator cassandraHostConfigurator;
private Cluster cluster;
private final Cluster cluster;

public CassandraClientPoolImpl(CassandraClientMonitor clientMonitor) {
log.info("Creating a CassandraClientPool");
Expand All @@ -55,14 +55,12 @@ public CassandraClientPoolImpl(CassandraClientMonitor clientMonitor,
log.debug("Maybe creating pool-by-host instance for {} at {}", cassandraHost, this);
getPool(cassandraHost);
}
this.cluster = new ThriftCluster("Default Cluster", this);
}

public CassandraClientPoolImpl(CassandraClientMonitor clientMonitor,
CassandraHostConfigurator cassandraHostConfigurator) {
this(clientMonitor, cassandraHostConfigurator.buildCassandraHosts());
this.cassandraHostConfigurator = cassandraHostConfigurator;
this.cluster = new ThriftCluster("Default Cluster", this);
}


Expand Down

0 comments on commit b8d289e

Please sign in to comment.