public void restartConnection() {
}},"requester-1"), cfg);
future.join();
session = future.getSession();
} catch (RuntimeIOException e) {
<BUG>logger.error("Failed to connect to "+host+":"+port);

logger.error( e.getMessage(),e);</BUG>
}finally {
if (session!=null)

public void restartConnection() {
}},"requester-1"), cfg);
future.join();
session = future.getSession();
} catch (RuntimeIOException e) {
logger.error("Failed to connect to "+host+":"+port+": "+e.getMessage());
}finally {
if (session!=null)
