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

java.lang.Object
  extended by 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
TcpTransportFactory()
           
 
Method Summary
 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()

-->

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