public void reconnect ( ) { metadata = cluster . getMetadata ( ) ; LOGGER . debug ( "Connected to cluster (" + host + "): " + metadata . getClusterName ( ) + "\n" ) ; this . session = this . cluster . connect ( ) ; }
Reconnect to Cassandra host .