Infinispan Distribution 5.2.6.Final-redhat-2

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

java.lang.Object
  extended by org.apache.commons.pool.BaseKeyedPoolableObjectFactory<SocketAddress,TcpTransport>
      extended by 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
TransportObjectFactory(Codec codec, TcpTransportFactory tcpTransportFactory, AtomicInteger topologyId, boolean pingOnStartup)
           
 
Method Summary
 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

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.