1 package com.thinkaurelius.titan.diskstorage.cassandra.thrift.thriftpool;
3 import org.apache.cassandra.thrift.Cassandra;
4 import org.apache.cassandra.thrift.Cassandra.Client;
5 import org.apache.thrift.transport.TTransport;
7 import java.io.Closeable;
10 * Wraps a {@code Cassandra.Client} instance, its underlying {@code TTransport}
11 * instance, and the {@link com.thinkaurelius.titan.diskstorage.cassandra.thrift.thriftpool.CTConnectionFactory.Config} instance used to setup
14 * @see CTConnectionFactory
15 * @see CTConnectionPool
16 * @author Dan LaRocque <dalaro@hopcount.org>
18 public class CTConnection implements Closeable {
20 private final TTransport transport;
21 private final Cassandra.Client client;
22 private final CTConnectionFactory.Config cfg;
24 public CTConnection(TTransport transport, Client client, CTConnectionFactory.Config cfg) {
25 this.transport = transport;
30 public TTransport getTransport() {
34 public Cassandra.Client getClient() {
38 public CTConnectionFactory.Config getConfig() {
42 public boolean isOpen() {
43 return transport.isOpen();
47 if (transport != null && transport.isOpen())
52 public String toString() {
53 return "CTConnection [transport=" + transport + ", client=" + client + ", cfg=" + cfg + "]";