akka.routing
Class ConsistentHashingRoutingLogic
java.lang.Object
akka.routing.ConsistentHashingRoutingLogic
- All Implemented Interfaces:
- NoSerializationVerificationNeeded, RoutingLogic, java.io.Serializable, scala.Equals, scala.Product
public final class ConsistentHashingRoutingLogic
- extends java.lang.Object
- implements RoutingLogic, scala.Product, scala.Serializable
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface scala.Product |
productArity, productElement, productIterator, productPrefix |
Methods inherited from interface scala.Equals |
canEqual, equals |
ConsistentHashingRoutingLogic
public ConsistentHashingRoutingLogic(ActorSystem system,
int virtualNodesFactor,
scala.PartialFunction<java.lang.Object,java.lang.Object> hashMapping)
ConsistentHashingRoutingLogic
public ConsistentHashingRoutingLogic(ActorSystem system)
defaultAddress
public static Address defaultAddress(ActorSystem system)
system
public ActorSystem system()
virtualNodesFactor
public int virtualNodesFactor()
hashMapping
public scala.PartialFunction<java.lang.Object,java.lang.Object> hashMapping()
vnodes
public int vnodes()
withVirtualNodesFactor
public ConsistentHashingRoutingLogic withVirtualNodesFactor(int vnodes)
withHashMapper
public ConsistentHashingRoutingLogic withHashMapper(ConsistentHashingRouter.ConsistentHashMapper mapper)
select
public Routee select(java.lang.Object message,
scala.collection.immutable.IndexedSeq<Routee> routees)
- Description copied from interface:
RoutingLogic
- Pick the destination for a given message. Normally it picks one of the
passed
routees
, but in the end it is up to the implementation to
return whatever Routee
to use for sending a specific message.
When implemented from Java it can be good to know that
routees.apply(index)
can be used to get an element
from the IndexedSeq
.
- Specified by:
select
in interface RoutingLogic
- Parameters:
message
- (undocumented)routees
- (undocumented)
- Returns:
- (undocumented)