private ConnectionPool getNewPool ( String host , int port ) { CassandraHost cassandraHost = ( ( CassandraHostConfiguration ) configuration ) . getCassandraHost ( host , port ) ; hostPools . remove ( cassandraHost ) ; if ( cassandraHost . isRetryHost ( ) ) { logger . warn ( "Scheduling node for future retry" ) ; ( ( CassandraRetryService ) hostRetryService ) . add ( ( CassandraHost ) cassandraHost ) ; } return getPoolUsingPolicy ( ) ; }
Gets the new pool .