com.github.phantomthief.thrift.client.pool.impl

Class DefaultThriftConnectionPoolImpl

java.lang.Object

com.github.phantomthief.thrift.client.pool.impl.DefaultThriftConnectionPoolImpl

All Implemented Interfaces:

ThriftConnectionPoolProvider

public final class DefaultThriftConnectionPoolImpl
extends Object
implements ThriftConnectionPoolProvider

DefaultThriftConnectionPoolImpl class.

Version:

$Id: $Id

Author:

w.vela

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultThriftConnectionPoolImpl.ThriftConnectionFactory

Constructor Summary

Constructors

Constructor and Description
DefaultThriftConnectionPoolImpl(org.apache.commons.pool2.impl.GenericKeyedObjectPoolConfig config) Constructor for DefaultThriftConnectionPoolImpl.
DefaultThriftConnectionPoolImpl(org.apache.commons.pool2.impl.GenericKeyedObjectPoolConfig config, java.util.function.Function<ThriftServerInfo,org.apache.thrift.transport.TTransport> transportProvider) Constructor for DefaultThriftConnectionPoolImpl.

Method Summary

Modifier and Type	Method and Description
org.apache.thrift.transport.TTransport	getConnection(ThriftServerInfo thriftServerInfo) getConnection.
static DefaultThriftConnectionPoolImpl	getInstance() getInstance.
void	returnBrokenConnection(ThriftServerInfo thriftServerInfo, org.apache.thrift.transport.TTransport transport) returnBrokenConnection.
void	returnConnection(ThriftServerInfo thriftServerInfo, org.apache.thrift.transport.TTransport transport) returnConnection.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultThriftConnectionPoolImpl

public DefaultThriftConnectionPoolImpl(org.apache.commons.pool2.impl.GenericKeyedObjectPoolConfig config,
                                       java.util.function.Function<ThriftServerInfo,org.apache.thrift.transport.TTransport> transportProvider)

Constructor for DefaultThriftConnectionPoolImpl.

Parameters:

config - a GenericKeyedObjectPoolConfig object.

transportProvider - a Function object.

DefaultThriftConnectionPoolImpl

public DefaultThriftConnectionPoolImpl(org.apache.commons.pool2.impl.GenericKeyedObjectPoolConfig config)

Constructor for DefaultThriftConnectionPoolImpl.

Parameters:

config - a GenericKeyedObjectPoolConfig object.

Method Detail

getInstance

public static final DefaultThriftConnectionPoolImpl getInstance()

getInstance.

Returns:

a DefaultThriftConnectionPoolImpl object.

getConnection

public org.apache.thrift.transport.TTransport getConnection(ThriftServerInfo thriftServerInfo)

getConnection.

Specified by:

getConnection in interface ThriftConnectionPoolProvider

Parameters:

thriftServerInfo - a ThriftServerInfo object.

Returns:

a TTransport object.

returnConnection

public void returnConnection(ThriftServerInfo thriftServerInfo,
                             org.apache.thrift.transport.TTransport transport)

returnConnection.

Specified by:

returnConnection in interface ThriftConnectionPoolProvider

Parameters:

thriftServerInfo - a ThriftServerInfo object.

transport - a TTransport object.

returnBrokenConnection

public void returnBrokenConnection(ThriftServerInfo thriftServerInfo,
                                   org.apache.thrift.transport.TTransport transport)

returnBrokenConnection.

Specified by:

returnBrokenConnection in interface ThriftConnectionPoolProvider

Parameters:

thriftServerInfo - a ThriftServerInfo object.

transport - a TTransport object.