com.lightbend.lagom.javadsl.persistence

Class PersistentEntity.CommandContext<R>

Object

com.lightbend.lagom.javadsl.persistence.PersistentEntity.ReadOnlyCommandContext<R>

com.lightbend.lagom.javadsl.persistence.PersistentEntity.CommandContext<R>

Enclosing class:

PersistentEntity<Command,Event,State>

public abstract class PersistentEntity.CommandContext<R>
extends PersistentEntity.ReadOnlyCommandContext<R>

The context that is passed to command handler function.

Constructor Summary

Constructors

Constructor and Description
CommandContext()

Method Summary

Modifier and Type	Method and Description
<B extends Event> PersistentEntity.Persist<B>	done() A command handler may return this Persist directive to define that no events are to be persisted.
<B extends Event> PersistentEntity.Persist<B>	thenPersist(B event) A command handler may return this Persist directive to define that one event is to be persisted.
<B extends Event> PersistentEntity.Persist<B>	thenPersist(B event, Consumer<B> afterPersist) A command handler may return this Persist directive to define that one event is to be persisted.
<B extends Event> PersistentEntity.Persist<B>	thenPersistAll(akka.japi.Effect afterPersist, Object... events) A command handler may return this Persist directive to define that several events are to be persisted.
<B extends Event> PersistentEntity.Persist<B>	thenPersistAll(akka.japi.Effect afterPersist, scala.collection.Seq<B> events) A command handler may return this Persist directive to define that several events are to be persisted.
<B extends Event> PersistentEntity.Persist<B>	thenPersistAll(List<B> events) A command handler may return this Persist directive to define that several events are to be persisted.
<B extends Event> PersistentEntity.Persist<B>	thenPersistAll(List<B> events, akka.japi.Effect afterPersist) A command handler may return this Persist directive to define that several events are to be persisted.

Methods inherited from class com.lightbend.lagom.javadsl.persistence.PersistentEntity.ReadOnlyCommandContext

commandFailed, invalidCommand, reply

Methods inherited from class Object

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

Constructor Detail

CommandContext

public CommandContext()

Method Detail

done

public <B extends Event> PersistentEntity.Persist<B> done()

A command handler may return this Persist directive to define that no events are to be persisted.

thenPersist

public <B extends Event> PersistentEntity.Persist<B> thenPersist(B event)

A command handler may return this Persist directive to define that one event is to be persisted.

thenPersist

public <B extends Event> PersistentEntity.Persist<B> thenPersist(B event,
                                                                 Consumer<B> afterPersist)

A command handler may return this Persist directive to define that one event is to be persisted. External side effects can be performed after successful persist in the afterPersist function.

thenPersistAll

public <B extends Event> PersistentEntity.Persist<B> thenPersistAll(akka.japi.Effect afterPersist,
                                                                    Object... events)

A command handler may return this Persist directive to define that several events are to be persisted. External side effects can be performed after successful persist in the afterPersist function. afterPersist is invoked once when all events have been persisted successfully.

thenPersistAll

public <B extends Event> PersistentEntity.Persist<B> thenPersistAll(List<B> events)

A command handler may return this Persist directive to define that several events are to be persisted. Events will be persisted atomically and in the same order as they are passed here.

thenPersistAll

public <B extends Event> PersistentEntity.Persist<B> thenPersistAll(List<B> events,
                                                                    akka.japi.Effect afterPersist)

A command handler may return this Persist directive to define that several events are to be persisted. External side effects can be performed after successful persist in the afterPersist function. afterPersist is invoked once when all events have been persisted successfully. Events will be persisted atomically and in the same order as they are passed here.

thenPersistAll

public <B extends Event> PersistentEntity.Persist<B> thenPersistAll(akka.japi.Effect afterPersist,
                                                                    scala.collection.Seq<B> events)

A command handler may return this Persist directive to define that several events are to be persisted. External side effects can be performed after successful persist in the afterPersist function. afterPersist is invoked once when all events have been persisted successfully.