Package org.apache.pekko.routing
Interface ConsistentHashingRouter.ConsistentHashable
-
- All Known Implementing Classes:
ConsistentHashingRouter.ConsistentHashableEnvelope
,Dns.Resolve
,DnsProtocol.Resolve
- Enclosing class:
- ConsistentHashingRouter
public 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. Note that it's not the hash, but the data to be hashed.If returning an
Array[Byte]
or String it will be used as is, otherwise the configuredpekko.serialization.Serializer
will be applied to the returned data.If messages can't implement this interface themselves, it's possible to wrap the messages in
pekko.routing.ConsistentHashingRouter.ConsistentHashableEnvelope
, or usepekko.routing.ConsistentHashingRouter.ConsistentHashableEnvelope
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.lang.Object
consistentHashKey()
-