public class ConsistentHashingRouter
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static interface |
ConsistentHashingRouter.ConsistentHashable
If you don't define the
hashMapping when
constructing the 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 the
hashMapping when
constructing the ConsistentHashingRouter
and messages can't implement 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 and Description |
---|
ConsistentHashingRouter() |
Modifier and Type | Method and Description |
---|---|
static scala.PartialFunction<java.lang.Object,java.lang.Object> |
hashMappingAdapter(ConsistentHashingRouter.ConsistentHashMapper mapper)
INTERNAL API
|
public static scala.PartialFunction<java.lang.Object,java.lang.Object> hashMappingAdapter(ConsistentHashingRouter.ConsistentHashMapper mapper)
mapper
- (undocumented)