Package org.apache.pekko.persistence.testkit.javadsl

Class PersistenceProbeBehavior<Command,Event,State>

java.lang.Object

org.apache.pekko.persistence.testkit.javadsl.PersistenceProbeBehavior<Command,Event,State>

public final class PersistenceProbeBehavior<Command,Event,State>
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
PersistenceProbeBehavior()

Method Summary

Modifier and Type	Method	Description
static <Command,State> PersistenceProbeBehavior<Command,java.lang.Void,State>	fromDurableState(Behavior<Command> behavior)
static <Command,State> PersistenceProbeBehavior<Command,java.lang.Void,State>	fromDurableState(Behavior<Command> behavior, State initialState)
static <Command,Event,State> PersistenceProbeBehavior<Command,Event,State>	fromEventSourced(Behavior<Command> behavior)
static <Command,Event,State> PersistenceProbeBehavior<Command,Event,State>	fromEventSourced(Behavior<Command> behavior, State initialState, long initialSequenceNr)	Given an EventSourcedBehavior, produce a non-persistent Behavior which synchronously publishes events and snapshots for inspection.
Behavior<Command>	getBehavior()
BehaviorTestKit<Command>	getBehaviorTestKit()
PersistenceProbe<Event>	getEventProbe()	Note: durable state behaviors will not publish events to this probe
PersistenceProbe<State>	getSnapshotProbe()
PersistenceProbe<State>	getStateProbe()

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceProbeBehavior

public PersistenceProbeBehavior()

Method Detail

fromEventSourced

public static <Command,Event,State> PersistenceProbeBehavior<Command,Event,State> fromEventSourced(Behavior<Command> behavior,
                                                                                                                           State initialState,
                                                                                                                           long initialSequenceNr)

Given an EventSourcedBehavior, produce a non-persistent Behavior which synchronously publishes events and snapshots for inspection. State is updated as in the EventSourcedBehavior, and side effects are performed synchronously. The resulting Behavior is, contingent on the command handling, event handling, and side effects being compatible with the BehaviorTestKit, testable with the BehaviorTestKit.

The returned Behavior does not intrinsically depend on configuration: it therefore does not serialize and assumes an unbounded stash for commands.

Parameters:

behavior - a (possibly wrapped) EventSourcedBehavior to serve as the basis for the persistenceProbe behavior

initialState - start the persistenceProbe behavior with this state; if null, behavior's initialState will be used

initialSequenceNr - start the persistenceProbe behavior with this sequence number; only applies if initialState is non-null

Returns:

an PersistenceProbeBehavior based on an EventSourcedBehavior

fromEventSourced

public static <Command,Event,State> PersistenceProbeBehavior<Command,Event,State> fromEventSourced(Behavior<Command> behavior)

fromDurableState

public static <Command,State> PersistenceProbeBehavior<Command,java.lang.Void,State> fromDurableState(Behavior<Command> behavior,
                                                                                                                        State initialState)

fromDurableState

public static <Command,State> PersistenceProbeBehavior<Command,java.lang.Void,State> fromDurableState(Behavior<Command> behavior)

getBehavior

public Behavior<Command> getBehavior()

getBehaviorTestKit

public BehaviorTestKit<Command> getBehaviorTestKit()

getEventProbe

public PersistenceProbe<Event> getEventProbe()

Note: durable state behaviors will not publish events to this probe

getStateProbe

public PersistenceProbe<State> getStateProbe()

getSnapshotProbe

public PersistenceProbe<State> getSnapshotProbe()