Package org.apache.pekko.cluster.sharding.typed

Class ShardingMessageExtractor$

java.lang.Object

org.apache.pekko.cluster.sharding.typed.ShardingMessageExtractor$

public class ShardingMessageExtractor$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final ShardingMessageExtractor$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ShardingMessageExtractor$()

Method Summary

Modifier and Type	Method	Description
<M> ShardingMessageExtractor<ShardingEnvelope<M>,M>	apply(int numberOfShards)	Scala API:
<M> ShardingMessageExtractor<M,M>	noEnvelope(int numberOfShards, M stopMessage, scala.Function1<M,String> extractEntityId)	Scala API: Create a message extractor for a protocol where the entity id is available in each message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final ShardingMessageExtractor$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ShardingMessageExtractor$

public ShardingMessageExtractor$()

Method Details

apply

public <M>
ShardingMessageExtractor<ShardingEnvelope<M>,M> apply(int numberOfShards)

Scala API:

Create the default message extractor, using envelopes to identify what entity a message is for and the hashcode of the entityId to decide which shard an entity belongs to.

This is recommended since it does not force details about sharding into the entity protocol

noEnvelope

public <M> ShardingMessageExtractor<M,M> noEnvelope(int numberOfShards,
 M stopMessage,
 scala.Function1<M,String> extractEntityId)

Scala API: Create a message extractor for a protocol where the entity id is available in each message.