@ThreadSafe public class TcpTransportFactory extends Object implements TransportFactory
Constructor and Description |
---|
TcpTransportFactory() |
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) |
public void start(Codec codec, Configuration configuration, AtomicInteger topologyId)
start
in interface TransportFactory
public void destroy()
destroy
in interface TransportFactory
public void updateHashFunction(Map<SocketAddress,Set<Integer>> servers2Hash, int numKeyOwners, short hashFunctionVersion, int hashSpace)
updateHashFunction
in interface TransportFactory
public Transport getTransport()
getTransport
in interface TransportFactory
public Transport getTransport(byte[] key)
getTransport
in interface TransportFactory
public void releaseTransport(Transport transport)
releaseTransport
in interface TransportFactory
public void invalidateTransport(SocketAddress serverAddress, Transport transport)
invalidateTransport
in interface TransportFactory
public void updateServers(Collection<SocketAddress> newServers)
updateServers
in interface TransportFactory
public Collection<SocketAddress> getServers()
public ConsistentHash getConsistentHash()
ConsistentHash
may not be thread-safe.public ConsistentHashFactory getConsistentHashFactory()
getConsistentHashFactory
in interface TransportFactory
public boolean isTcpNoDelay()
isTcpNoDelay
in interface TransportFactory
public int getTransportCount()
getTransportCount
in interface TransportFactory
public int getSoTimeout()
getSoTimeout
in interface TransportFactory
public int getConnectTimeout()
getConnectTimeout
in interface TransportFactory
public SSLContext getSSLContext()
getSSLContext
in interface TransportFactory
public RequestBalancingStrategy getBalancer()
RequestBalancingStrategy
may not be thread-safe.public org.apache.commons.pool.impl.GenericKeyedObjectPool<SocketAddress,TcpTransport> getConnectionPool()
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.