Java API
Java API
the actor system hosting this router
the actor system hosting this router
number of virtual nodes per node, used in akka.routing.ConsistentHash
partial function from message to the data to use for the consistent hash key
partial function from message to the data to use for the consistent hash key
Pick the destination for a given message.
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
.
the actor system hosting this router
number of virtual nodes per node, used in akka.routing.ConsistentHash
Java API: Setting the mapping from message to the data to use for the consistent hash key.
Setting the number of virtual nodes per node, used in akka.routing.ConsistentHash
Uses consistent hashing to select a routee based on the sent message.
There is 3 ways to define what data to use for the consistent hash key.
1. You can define
hashMapping
/withHashMapper
of the router to map incoming messages to their consistent hash key. This makes the decision transparent for the sender.2. The messages may implement akka.routing.ConsistentHashingRouter.ConsistentHashable. The key is part of the message and it's convenient to define it together with the message definition.
3. The messages can be be wrapped in a akka.routing.ConsistentHashingRouter.ConsistentHashableEnvelope to define what data to use for the consistent hash key. The sender knows the key to use.
These ways to define the consistent hash key can be use together and at the same time for one router. The
hashMapping
is tried first.the actor system hosting this router
number of virtual nodes per node, used in akka.routing.ConsistentHash
partial function from message to the data to use for the consistent hash key