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 of ShardRegion.MessageExtractor that construct shardId based on the hashCode of the entityId. The number of unique shards is limited by the given maxNumberOfShards.

Constructor Summary

Constructors

Constructor and Description
HashCodeMessageExtractor(int maxNumberOfShards)

Method Summary

Modifier and Type	Method and 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 entity id from an incoming message.

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

Constructor Detail

HashCodeMessageExtractor

public HashCodeMessageExtractor(int maxNumberOfShards)

Method Detail

entityMessage

public java.lang.Object entityMessage(java.lang.Object message)

Default implementation pass on the message as is.

Specified by:

entityMessage in interface ShardRegion.MessageExtractor

Parameters:

message - (undocumented)

Returns:

(undocumented)

shardId

public java.lang.String shardId(java.lang.Object message)

Description copied from interface: ShardRegion.MessageExtractor

Extract the entity id from an incoming message. Only messages that passed the ShardRegion.MessageExtractor.entityId(java.lang.Object) function will be used as input to this function.

Specified by:

shardId in interface ShardRegion.MessageExtractor

Parameters:

message - (undocumented)

Returns:

(undocumented)