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()
           
 ConsistentHash getConsistentHash()
          Note that the returned ConsistentHash may not be thread-safe.
 Collection<SocketAddress> getServers()
           
 int getSoTimeout()
           
 Transport getTransport()
           
 Transport getTransport(byte[] key)
           
 int getTransportCount()
           
 boolean isTcpNoDelay()
           
 void releaseTransport(Transport transport)
           
 void start(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(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.


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

getBalancer

public RequestBalancingStrategy getBalancer()
Note that the returned RequestBalancingStrategy may not be thread-safe.


getConnectionPool

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

-->

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