### Question:
Cluster implements Closeable { public Cluster(String host, int port, Configuration configuration) { this.host = host; this.port = port; this.configuration = configuration; this.masterSession = new Session(host, port, configuration); } Cluster(String host, int port, Configuration configuration);  Cluster(Builder builder); static Cluster.Builder builder(); Session connect(); Session newSession(); void close(Session session); BlockingQueue<Session> getSessions(); @Override void close();  }### Answer:
@Test public void testCluster() throws IOException { Configuration configuration = new Configuration.Builder().build(); Cluster cluster = new Cluster.Builder().withAddress(host).withPort(port) .withConfiguration(configuration).build(); try { cluster.connect(); }catch (Exception e) { }finally { cluster.close(); } }