Package org.apache.pekko.persistence.typed.javadsl

Class EventSourcedBehaviorWithEnforcedReplies<Command,Event,State>

java.lang.Object

org.apache.pekko.actor.typed.Behavior<T>

org.apache.pekko.actor.typed.internal.BehaviorImpl.DeferredBehavior<Command>

org.apache.pekko.persistence.typed.javadsl.EventSourcedBehavior<Command,Event,State>

org.apache.pekko.persistence.typed.javadsl.EventSourcedBehaviorWithEnforcedReplies<Command,Event,State>

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

A EventSourcedBehavior that is enforcing that replies to commands are not forgotten. There will be compilation errors if the returned effect isn't a ReplyEffect, which can be created with Effects().reply, Effects().noReply, EffectBuilder.thenReply, or EffectBuilder.thenNoReply.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.actor.typed.Behavior

Behavior.BehaviorDecorators<Inner>, Behavior.BehaviorDecorators$

Constructor Summary

Constructors

Constructor	Description
EventSourcedBehaviorWithEnforcedReplies(PersistenceId persistenceId)
EventSourcedBehaviorWithEnforcedReplies(PersistenceId persistenceId, Optional<BackoffSupervisorStrategy> backoffSupervisorStrategy)
EventSourcedBehaviorWithEnforcedReplies(PersistenceId persistenceId, BackoffSupervisorStrategy backoffSupervisorStrategy)

Method Summary

Modifier and Type	Method	Description
protected abstract CommandHandlerWithReply<Command,Event,State>	commandHandler()	Implement by handling incoming commands and return an Effect() to persist or signal other effects of the command handling such as stopping the behavior or others.
protected CommandHandlerBuilder<Command,Event,State>	newCommandHandlerBuilder()	Use newCommandHandlerWithReplyBuilder() instead, or extend EventSourcedBehavior instead of EventSourcedBehaviorWithEnforcedReplies.
protected CommandHandlerWithReplyBuilder<Command,Event,State>	newCommandHandlerWithReplyBuilder()

Methods inherited from class org.apache.pekko.persistence.typed.javadsl.EventSourcedBehavior

apply, Effect, emptyState, eventAdapter, eventHandler, journalPluginConfig, journalPluginId, lastSequenceNumber, newEventHandlerBuilder, newSignalHandlerBuilder, persistenceId, recovery, retentionCriteria, shouldSnapshot, signalHandler, snapshotAdapter, snapshotPluginConfig, snapshotPluginId, tagsFor

Methods inherited from class org.apache.pekko.actor.typed.Behavior

BehaviorDecorators, canonicalize, existsInStack, interpretMessage, interpretSignal, isAlive, isDeferred, isUnhandled, narrow, start, validateAsInitial

Methods inherited from class java.lang.Object

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

Constructor Details

EventSourcedBehaviorWithEnforcedReplies

public EventSourcedBehaviorWithEnforcedReplies(PersistenceId persistenceId,
 Optional<BackoffSupervisorStrategy> backoffSupervisorStrategy)

EventSourcedBehaviorWithEnforcedReplies

public EventSourcedBehaviorWithEnforcedReplies(PersistenceId persistenceId)

EventSourcedBehaviorWithEnforcedReplies

public EventSourcedBehaviorWithEnforcedReplies(PersistenceId persistenceId,
 BackoffSupervisorStrategy backoffSupervisorStrategy)

Method Details

commandHandler

protected abstract CommandHandlerWithReply<Command,Event,State> commandHandler()

Implement by handling incoming commands and return an Effect() to persist or signal other effects of the command handling such as stopping the behavior or others.

Use newCommandHandlerWithReplyBuilder() to define the command handlers.

The command handlers are only invoked when the actor is running (i.e. not replaying). While the actor is persisting events, the incoming messages are stashed and only delivered to the handler once persisting them has completed.

Specified by:

commandHandler in class EventSourcedBehavior<Command,Event,State>

newCommandHandlerBuilder

protected CommandHandlerBuilder<Command,Event,State> newCommandHandlerBuilder()

Use newCommandHandlerWithReplyBuilder() instead, or extend EventSourcedBehavior instead of EventSourcedBehaviorWithEnforcedReplies.

Overrides:

newCommandHandlerBuilder in class EventSourcedBehavior<Command,Event,State>

Returns:

A new, mutable, command handler builder

Throws:

UnsupportedOperationException - use newCommandHandlerWithReplyBuilder instead

newCommandHandlerWithReplyBuilder

protected CommandHandlerWithReplyBuilder<Command,Event,State> newCommandHandlerWithReplyBuilder()

Returns:

A new, mutable, command handler builder