public class TransportObjectFactory extends org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
Modifier and Type | Field and Description |
---|---|
protected Codec |
codec |
protected AtomicInteger |
defaultCacheTopologyId |
protected boolean |
firstPingExecuted |
protected boolean |
pingOnStartup |
protected TcpTransportFactory |
tcpTransportFactory |
Constructor and Description |
---|
TransportObjectFactory(Codec codec,
TcpTransportFactory tcpTransportFactory,
AtomicInteger defaultCacheTopologyId,
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) |
protected PingOperation.PingResult |
ping(TcpTransport tcpTransport,
AtomicInteger topologyId) |
boolean |
validateObject(SocketAddress address,
TcpTransport transport)
This will be called by the test thread when testWhileIdle==true.
|
protected final TcpTransportFactory tcpTransportFactory
protected final AtomicInteger defaultCacheTopologyId
protected final boolean pingOnStartup
protected volatile boolean firstPingExecuted
protected final Codec codec
public TransportObjectFactory(Codec codec, TcpTransportFactory tcpTransportFactory, AtomicInteger defaultCacheTopologyId, 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
protected PingOperation.PingResult ping(TcpTransport tcpTransport, AtomicInteger topologyId)
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 © 2018 JBoss, a division of Red Hat. All rights reserved.