Package org.apache.pekko.routing
Class ConsistentHashingRouter
- java.lang.Object
-
- org.apache.pekko.routing.ConsistentHashingRouter
-
public class ConsistentHashingRouter extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
ConsistentHashingRouter.ConsistentHashable
If you don't define thehashMapping
when constructing thepekko.routing.ConsistentHashingRouter
the messages need to implement this interface to define what data to use for the consistent hash key.static class
ConsistentHashingRouter.ConsistentHashableEnvelope
If you don't define thehashMapping
when constructing thepekko.routing.ConsistentHashingRouter
and messages can't implementpekko.routing.ConsistentHashingRouter.ConsistentHashable
themselves they can we wrapped by this envelope instead.static class
ConsistentHashingRouter.ConsistentHashableEnvelope$
static interface
ConsistentHashingRouter.ConsistentHashMapper
JAVA API Mapping from message to the data to use for the consistent hash key.static class
ConsistentHashingRouter.emptyConsistentHashMapping$
-
Constructor Summary
Constructors Constructor Description ConsistentHashingRouter()
-