Package akka.cluster.sharding
Class ShardRegion.HashCodeMessageExtractor
- java.lang.Object
-
- akka.cluster.sharding.ShardRegion.HashCodeMessageExtractor
-
- All Implemented Interfaces:
ShardRegion.MessageExtractor
- Enclosing class:
- ShardRegion
public abstract static class ShardRegion.HashCodeMessageExtractor extends java.lang.Object implements ShardRegion.MessageExtractor
Convenience implementation ofShardRegion.MessageExtractor
that constructshardId
based on thehashCode
of theentityId
. The number of unique shards is limited by the givenmaxNumberOfShards
.
-
-
Constructor Summary
Constructors Constructor Description HashCodeMessageExtractor(int maxNumberOfShards)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
entityMessage(java.lang.Object message)
Default implementation pass on the message as is.java.lang.String
shardId(java.lang.Object message)
Extract the shard id from an incomingmessage
.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.cluster.sharding.ShardRegion.MessageExtractor
entityId
-
-
-
-
Method Detail
-
entityMessage
public java.lang.Object entityMessage(java.lang.Object message)
Default implementation pass on the message as is.- Specified by:
entityMessage
in interfaceShardRegion.MessageExtractor
-
shardId
public java.lang.String shardId(java.lang.Object message)
Description copied from interface:ShardRegion.MessageExtractor
Extract the shard id from an incomingmessage
. Only messages that passed theShardRegion.MessageExtractor.entityId(java.lang.Object)
function will be used as input to this function.- Specified by:
shardId
in interfaceShardRegion.MessageExtractor
-
-