Package akka.cluster.sharding.typed.javadsl

Class EventSourcedEntity<Command,Event,State>

java.lang.Object

akka.actor.typed.Behavior<T>

akka.actor.typed.Behavior.DeferredBehavior<Command>

akka.persistence.typed.javadsl.EventSourcedBehavior<Command,Event,State>

akka.cluster.sharding.typed.javadsl.EventSourcedEntity<Command,Event,State>

public abstract class EventSourcedEntity<Command,Event,State>
extends EventSourcedBehavior<Command,Event,State>

Any Behavior can be used as a sharded entity actor, but the combination of sharding and persistent actors is very common and therefore this PersistentEntity class is provided as convenience.

It is a EventSourcedBehavior and is implemented in the same way. It selects the persistenceId automatically from the EntityTypeKey and entityId constructor parameters by using EntityTypeKey.persistenceIdFrom.

Nested Class Summary

Nested classes/interfaces inherited from class akka.actor.typed.Behavior

Behavior.BehaviorDecorators<T>, Behavior.BehaviorDecorators$, Behavior.DeferredBehavior<T>, Behavior.DeferredBehavior$, Behavior.EmptyBehavior$, Behavior.FailedBehavior, Behavior.IgnoreBehavior$, Behavior.SameBehavior$, Behavior.StoppedBehavior<T>, Behavior.StoppedBehavior$, Behavior.UnhandledBehavior$

Constructor Summary

Constructors

Constructor	Description
EventSourcedEntity(EntityTypeKey<Command> entityTypeKey, java.lang.String entityId)
EventSourcedEntity(EntityTypeKey<Command> entityTypeKey, java.lang.String entityId, BackoffSupervisorStrategy onPersistFailure)

Method Summary

Modifier and Type	Method	Description
java.lang.String	entityId()
EntityTypeKey<Command>	entityTypeKey()

Methods inherited from class akka.persistence.typed.javadsl.EventSourcedBehavior

apply, commandHandler, Effect, emptyState, eventAdapter, eventHandler, journalPluginId, lastSequenceNumber, newCommandHandlerBuilder, newEventHandlerBuilder, newSignalHandlerBuilder, persistenceId, retentionCriteria, shouldSnapshot, signalHandler, snapshotPluginId, snapshotSelectionCriteria, tagsFor

Methods inherited from class akka.actor.typed.Behavior

_tag, BehaviorDecorators, canonicalize, empty, existsInStack, failed, ignore, interpretMessage, interpretSignal, isAlive, isDeferred, isUnhandled, narrow, orElse, same, start, stopped, stopped, unhandled, unhandledSignal, unsafeCast, validateAsInitial

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSourcedEntity

public EventSourcedEntity(EntityTypeKey<Command> entityTypeKey,
                          java.lang.String entityId)

EventSourcedEntity

public EventSourcedEntity(EntityTypeKey<Command> entityTypeKey,
                          java.lang.String entityId,
                          BackoffSupervisorStrategy onPersistFailure)

Method Detail

entityId

public java.lang.String entityId()

entityTypeKey

public EntityTypeKey<Command> entityTypeKey()