akka.persistence.multidc.javadsl

Class ReplicatedEntity$

java.lang.Object

akka.persistence.multidc.javadsl.ReplicatedEntity$

public class ReplicatedEntity$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ReplicatedEntity$()

Method Summary

Modifier and Type	Method and Description
<Command,Event,State> akka.actor.Props	clusterShardingProps(java.lang.Class<Command> commandClass, java.lang.String entityTypeName, java.util.function.Supplier<ReplicatedEntity<Command,Event,State>> entityFactory, PersistenceMultiDcSettings settings) The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.
<Command,Event,State> akka.actor.Props	props(java.lang.Class<Command> commandClass, java.lang.String persistenceIdPrefix, java.lang.String entityId, java.util.function.Supplier<ReplicatedEntity<Command,Event,State>> entityFactory, PersistenceMultiDcSettings settings) The Props for the actor that can run a ReplicatedEntity.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final ReplicatedEntity$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ReplicatedEntity$

public ReplicatedEntity$()

Method Detail

props

public <Command,Event,State> akka.actor.Props props(java.lang.Class<Command> commandClass,
                                                    java.lang.String persistenceIdPrefix,
                                                    java.lang.String entityId,
                                                    java.util.function.Supplier<ReplicatedEntity<Command,Event,State>> entityFactory,
                                                    PersistenceMultiDcSettings settings)

The Props for the actor that can run a ReplicatedEntity.

Use clusterShardingProps(java.lang.Class<Command>, java.lang.String, java.util.function.Supplier<akka.persistence.multidc.javadsl.ReplicatedEntity<Command, Event, State>>, akka.persistence.multidc.PersistenceMultiDcSettings) instead when using Cluster Sharding.

Parameters:

persistenceIdPrefix - Prefix for the persistenceId, which is concatenated with the entityId and the data center identifier. Empty string is a valid prefix if the entityId itself is globally unique. Note that this can't be changed, since it is part of the storage key (persistenceId).

entityId - The identifier of the entity. The persistenceId includes this entityId and is concatenated with persistenceIdPrefix and the data center identifier.

entityFactory - Factory for creating a new instance of the entity. It has to be a factory so that a new instance is created in case the actor is restarted.

settings - Configuration settings.

commandClass - (undocumented)

Returns:

(undocumented)

clusterShardingProps

public <Command,Event,State> akka.actor.Props clusterShardingProps(java.lang.Class<Command> commandClass,
                                                                   java.lang.String entityTypeName,
                                                                   java.util.function.Supplier<ReplicatedEntity<Command,Event,State>> entityFactory,
                                                                   PersistenceMultiDcSettings settings)

The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.

Parameters:

entityTypeName - Use the same as the entity type name in Cluster Sharding. It is a prefix for the persistenceId, which is concatenated with the entityId and the data center identifier. Note that this can't be changed, since it is part of the storage key (persistenceId).

entityFactory - Factory for creating a new instance of the entity. It has to be a factory so that a new instance is created in case the actor is restarted.

settings - Configuration settings.

commandClass - (undocumented)

Returns:

(undocumented)