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

Class TcpTransportFactory

java.lang.Object

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

All Implemented Interfaces:

TransportFactory

@ThreadSafe
public class TcpTransportFactory
extends Object
implements TransportFactory

Since:

4.1

Author:

Mircea.Markus@jboss.com

Constructor Summary

Constructors

Constructor and Description
TcpTransportFactory()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
RequestBalancingStrategy	getBalancer() Note that the returned RequestBalancingStrategy may not be thread-safe.
org.apache.commons.pool.impl.GenericKeyedObjectPool	getConnectionPool()
int	getConnectTimeout()
ConsistentHash	getConsistentHash() Note that the returned ConsistentHash may not be thread-safe.
ConsistentHashFactory	getConsistentHashFactory()
Collection<SocketAddress>	getServers()
int	getSoTimeout()
Transport	getTransport()
Transport	getTransport(byte[] key)
int	getTransportCount()
boolean	isTcpNoDelay()
void	releaseTransport(Transport transport)
void	start(Codec codec, ConfigurationProperties cfg, Collection<SocketAddress> staticConfiguredServers, AtomicInteger topologyId, ClassLoader classLoader)
void	updateHashFunction(Map<SocketAddress,Set<Integer>> servers2Hash, int numKeyOwners, short hashFunctionVersion, int hashSpace)
void	updateServers(Collection<SocketAddress> newServers)

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpTransportFactory

public TcpTransportFactory()

Method Detail

start

public void start(Codec codec,
         ConfigurationProperties cfg,
         Collection<SocketAddress> staticConfiguredServers,
         AtomicInteger topologyId,
         ClassLoader classLoader)

Specified by:

start in interface TransportFactory

destroy

public void destroy()

Specified by:

destroy in interface TransportFactory

updateHashFunction

public void updateHashFunction(Map<SocketAddress,Set<Integer>> servers2Hash,
                      int numKeyOwners,
                      short hashFunctionVersion,
                      int hashSpace)

Specified by:

updateHashFunction in interface TransportFactory

getTransport

public Transport getTransport()

Specified by:

getTransport in interface TransportFactory

getTransport

public Transport getTransport(byte[] key)

Specified by:

getTransport in interface TransportFactory

releaseTransport

public void releaseTransport(Transport transport)

Specified by:

releaseTransport in interface TransportFactory

updateServers

public void updateServers(Collection<SocketAddress> newServers)

Specified by:

updateServers in interface TransportFactory

getServers

public Collection<SocketAddress> getServers()

getConsistentHash

public ConsistentHash getConsistentHash()

Note that the returned ConsistentHash may not be thread-safe.

getConsistentHashFactory

public ConsistentHashFactory getConsistentHashFactory()

Specified by:

getConsistentHashFactory in interface TransportFactory

isTcpNoDelay

public boolean isTcpNoDelay()

Specified by:

isTcpNoDelay in interface TransportFactory

getTransportCount

public int getTransportCount()

Specified by:

getTransportCount in interface TransportFactory

getSoTimeout

public int getSoTimeout()

Specified by:

getSoTimeout in interface TransportFactory

getConnectTimeout

public int getConnectTimeout()

Specified by:

getConnectTimeout in interface TransportFactory

getBalancer

public RequestBalancingStrategy getBalancer()

Note that the returned RequestBalancingStrategy may not be thread-safe.

getConnectionPool

public org.apache.commons.pool.impl.GenericKeyedObjectPool getConnectionPool()