org.infinispan.client.hotrod.impl.transport.tcp

Class TransportObjectFactory

java.lang.Object

org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>

org.infinispan.client.hotrod.impl.transport.tcp.TransportObjectFactory

All Implemented Interfaces:

org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Direct Known Subclasses:

SaslTransportObjectFactory

public class TransportObjectFactory
extends org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Since:

4.1

Author:

Mircea.Markus@jboss.com

Field Summary

Fields

Modifier and Type	Field and Description
protected Codec	codec
protected Configuration	configuration
protected AtomicInteger	defaultCacheTopologyId
protected boolean	firstPingExecuted
protected boolean	pingOnStartup
protected TcpTransportFactory	tcpTransportFactory

Constructor Summary

Constructors

Constructor and Description
TransportObjectFactory(Codec codec, TcpTransportFactory tcpTransportFactory, AtomicInteger defaultCacheTopologyId, boolean pingOnStartup, Configuration configuration)

Method Summary

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.

Methods inherited from class java.lang.Object

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

Field Detail

tcpTransportFactory

protected final TcpTransportFactory tcpTransportFactory

defaultCacheTopologyId

protected final AtomicInteger defaultCacheTopologyId

pingOnStartup

protected final boolean pingOnStartup

firstPingExecuted

protected volatile boolean firstPingExecuted

codec

protected final Codec codec

configuration

protected final Configuration configuration

Constructor Detail

TransportObjectFactory

public TransportObjectFactory(Codec codec,
                              TcpTransportFactory tcpTransportFactory,
                              AtomicInteger defaultCacheTopologyId,
                              boolean pingOnStartup,
                              Configuration configuration)

Method Detail

makeObject

public TcpTransport makeObject(SocketAddress address)
                        throws Exception

Specified by:

makeObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Specified by:

makeObject in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Throws:

Exception

ping

protected PingOperation.PingResult ping(TcpTransport tcpTransport,
                                        AtomicInteger topologyId)

validateObject

public boolean validateObject(SocketAddress address,
                              TcpTransport transport)

This will be called by the test thread when testWhileIdle==true.

Specified by:

validateObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Overrides:

validateObject in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>

destroyObject

public void destroyObject(SocketAddress address,
                          TcpTransport transport)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Overrides:

destroyObject in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Throws:

Exception

activateObject

public void activateObject(SocketAddress address,
                           TcpTransport transport)
                    throws Exception

Specified by:

activateObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Overrides:

activateObject in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Throws:

Exception

passivateObject

public void passivateObject(SocketAddress address,
                            TcpTransport transport)
                     throws Exception

Specified by:

passivateObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Overrides:

passivateObject in class org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>

Throws:

Exception