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>

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

Since:

4.1

Author:

Mircea.Markus@jboss.com

Constructor Summary

Constructors

Constructor and Description
TransportObjectFactory(Codec codec, TcpTransportFactory tcpTransportFactory, AtomicInteger topologyId, boolean pingOnStartup)

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)
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

Constructor Detail

TransportObjectFactory

public TransportObjectFactory(Codec codec,
                              TcpTransportFactory tcpTransportFactory,
                              AtomicInteger topologyId,
                              boolean pingOnStartup)

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

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