public class TransportObjectFactory extends org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
Constructor and Description |
---|
TransportObjectFactory(Codec codec,
TcpTransportFactory tcpTransportFactory,
AtomicInteger topologyId,
boolean pingOnStartup) |
Modifier and Type | Method and Description |
---|---|
void |
activateObject(SocketAddress address,
TcpTransport transport) |
void |
destroyObject(SocketAddress address,
TcpTransport transport) |
TcpTransport |
makeObject(SocketAddress address) |
void |
passivateObject(SocketAddress address,
TcpTransport transport) |
boolean |
validateObject(SocketAddress address,
TcpTransport transport)
This will be called by the test thread when testWhileIdle==true.
|
public TransportObjectFactory(Codec codec, TcpTransportFactory tcpTransportFactory, AtomicInteger topologyId, boolean pingOnStartup)
public TcpTransport makeObject(SocketAddress address) throws Exception
makeObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>
makeObject
in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
Exception
public boolean validateObject(SocketAddress address, TcpTransport transport)
validateObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>
validateObject
in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
public void destroyObject(SocketAddress address, TcpTransport transport) throws Exception
destroyObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>
destroyObject
in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
Exception
public void activateObject(SocketAddress address, TcpTransport transport) throws Exception
activateObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>
activateObject
in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
Exception
public void passivateObject(SocketAddress address, TcpTransport transport) throws Exception
passivateObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>
passivateObject
in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
Exception
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.