diff --git a/core/src/main/java/me/prettyprint/cassandra/connection/CassandraHostRetryService.java b/core/src/main/java/me/prettyprint/cassandra/connection/CassandraHostRetryService.java
index 1cdd94b8e..5112b4a8e 100644
--- a/core/src/main/java/me/prettyprint/cassandra/connection/CassandraHostRetryService.java
+++ b/core/src/main/java/me/prettyprint/cassandra/connection/CassandraHostRetryService.java
@@ -96,8 +96,7 @@ public void run() {
       boolean reconnected = verifyConnection(cassandraHost);
       log.info("Downed Host retry status {} with host: {}", reconnected, cassandraHost.getName());
       if ( reconnected ) {
-        //cassandraClientPool.getCluster().addHost(cassandraHost, true);
-        connectionManager.addCassandraHost(cassandraHost);
+        reconnected = connectionManager.addCassandraHost(cassandraHost);
       }
       if ( !reconnected && cassandraHost != null ) {
         downedHostQueue.add(cassandraHost);
@@ -128,7 +127,4 @@ private boolean verifyConnection(CassandraHost cassandraHost) {
 
   }
 
-  // TODO create callable to handle checking
-
-  // perhaps wrap CassandraHost and add a lastRetryTime?
 }