org.scale7.cassandra.pelops.pool
Class DebuggingPool.PooledConnection

java.lang.Object
  org.scale7.cassandra.pelops.Connection
      org.scale7.cassandra.pelops.pool.DebuggingPool.PooledConnection

All Implemented Interfaces:

IConnection, IThriftPool.IPooledConnection

Enclosing class:

DebuggingPool

public class DebuggingPool.PooledConnection
extends Connection
implements IThriftPool.IPooledConnection

Nested Class Summary

Nested classes/interfaces inherited from interface org.scale7.cassandra.pelops.IConnection

IConnection.Config

Constructor Summary

DebuggingPool.PooledConnection(Cluster.Node node, String keyspace)

Method Summary

void	corrupted() Specify whether an exception has been thrown during usage of the connection.
void	release() Release a Connection that has previously been taken from the pool.

Methods inherited from class org.scale7.cassandra.pelops.Connection

close, getAPI, getNode, isOpen, open

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.scale7.cassandra.pelops.IConnection

close, getAPI, getNode, isOpen, open

Constructor Detail

DebuggingPool.PooledConnection

public DebuggingPool.PooledConnection(Cluster.Node node,
                                      String keyspace)
                               throws SocketException,
                                      org.apache.thrift.TException,
                                      org.apache.cassandra.thrift.InvalidRequestException

Throws:

SocketException

org.apache.thrift.TException

org.apache.cassandra.thrift.InvalidRequestException

Method Detail

release

public void release()

Description copied from interface: IThriftPool.IPooledConnection

Release a Connection that has previously been taken from the pool.

Specified by:

release in interface IThriftPool.IPooledConnection

corrupted

public void corrupted()

Description copied from interface: IThriftPool.IPooledConnection

Specify whether an exception has been thrown during usage of the connection. If an exception has been thrown, the connection will not re-used since it may be corrupted (for example, it may contain partially written data that disrupts the serialization of the Thrift protocol) however it is remains essential that all connection objects are released.

Specified by:

corrupted in interface IThriftPool.IPooledConnection