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

Class DefaultThriftConnectionPoolImpl.ThriftConnectionFactory

java.lang.Object

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

All Implemented Interfaces:

org.apache.commons.pool2.KeyedPooledObjectFactory<ThriftServerInfo,org.apache.thrift.transport.TTransport>

Enclosing class:

DefaultThriftConnectionPoolImpl

public static final class DefaultThriftConnectionPoolImpl.ThriftConnectionFactory
extends Object
implements org.apache.commons.pool2.KeyedPooledObjectFactory<ThriftServerInfo,org.apache.thrift.transport.TTransport>

Constructor Summary

Constructors

Constructor and Description
ThriftConnectionFactory(java.util.function.Function<ThriftServerInfo,org.apache.thrift.transport.TTransport> transportProvider)

Method Summary

Modifier and Type	Method and Description
void	activateObject(ThriftServerInfo info, org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)
void	destroyObject(ThriftServerInfo info, org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)
org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport>	makeObject(ThriftServerInfo info)
void	passivateObject(ThriftServerInfo info, org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)
boolean	validateObject(ThriftServerInfo info, org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThriftConnectionFactory

public ThriftConnectionFactory(java.util.function.Function<ThriftServerInfo,org.apache.thrift.transport.TTransport> transportProvider)

Parameters:

transportProvider -

Method Detail

makeObject

public org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> makeObject(ThriftServerInfo info)
                                                                                         throws Exception

Specified by:

makeObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<ThriftServerInfo,org.apache.thrift.transport.TTransport>

Throws:

Exception

destroyObject

public void destroyObject(ThriftServerInfo info,
                          org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<ThriftServerInfo,org.apache.thrift.transport.TTransport>

Throws:

Exception

validateObject

public boolean validateObject(ThriftServerInfo info,
                              org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)

Specified by:

validateObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<ThriftServerInfo,org.apache.thrift.transport.TTransport>

activateObject

public void activateObject(ThriftServerInfo info,
                           org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)
                    throws Exception

Specified by:

activateObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<ThriftServerInfo,org.apache.thrift.transport.TTransport>

Throws:

Exception

passivateObject

public void passivateObject(ThriftServerInfo info,
                            org.apache.commons.pool2.PooledObject<org.apache.thrift.transport.TTransport> p)
                     throws Exception

Specified by:

passivateObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<ThriftServerInfo,org.apache.thrift.transport.TTransport>

Throws:

Exception