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

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<SocketAddress,TcpTransport>	getConnectionPool()
int	getConnectTimeout()
ConsistentHash	getConsistentHash() Note that the returned ConsistentHash may not be thread-safe.
ConsistentHashFactory	getConsistentHashFactory()
Collection<SocketAddress>	getServers()
int	getSoTimeout()
SSLContext	getSSLContext()
Transport	getTransport()
Transport	getTransport(byte[] key)
int	getTransportCount()
void	invalidateTransport(SocketAddress serverAddress, Transport transport)
boolean	isTcpNoDelay()
void	releaseTransport(Transport transport)
void	start(Codec codec, Configuration configuration, AtomicInteger topologyId)
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,
                  Configuration configuration,
                  AtomicInteger topologyId)

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

invalidateTransport

public void invalidateTransport(SocketAddress serverAddress,
                                Transport transport)

Specified by:

invalidateTransport 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

getSSLContext

public SSLContext getSSLContext()

Specified by:

getSSLContext 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<SocketAddress,TcpTransport> getConnectionPool()