ShardingMessageExtractor$

java.lang.Object
- akka.cluster.sharding.typed.ShardingMessageExtractor$

public class ShardingMessageExtractor$
extends java.lang.Object

Field Summary

Fields
Modifier and Type Field Description

static ShardingMessageExtractor$ MODULE$
Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors
Constructor Description

ShardingMessageExtractor$()

Method Summary

All Methods Instance Methods Concrete Methods
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,java.lang.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 Detail
  - MODULE$
```
public static final ShardingMessageExtractor$ MODULE$
```
    Static reference to the singleton instance of this Scala object.
- Constructor Detail
  - ShardingMessageExtractor$
```
public ShardingMessageExtractor$()
```
- Method Detail
  - 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,java.lang.String> extractEntityId)
```
    Scala API: Create a message extractor for a protocol where the entity id is available in each message.