Class EventSourcedProducerQueue<A>
java.lang.Object
org.apache.pekko.persistence.typed.delivery.EventSourcedProducerQueue<A>
INTERNAL API
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final class
static class
-
Constructor Summary
ConstructorsConstructorDescriptionEventSourcedProducerQueue
(ActorContext<DurableProducerQueue.Command<A>> context, scala.concurrent.duration.FiniteDuration cleanupUnusedAfter) -
Method Summary
Modifier and TypeMethodDescriptionstatic <A> Behavior<DurableProducerQueue.Command<A>>
apply
(PersistenceId persistenceId) static <A> Behavior<DurableProducerQueue.Command<A>>
apply
(PersistenceId persistenceId, EventSourcedProducerQueue.Settings settings) static <A> Behavior<DurableProducerQueue.Command<A>>
create
(PersistenceId persistenceId) Java APIstatic <A> Behavior<DurableProducerQueue.Command<A>>
create
(PersistenceId persistenceId, EventSourcedProducerQueue.Settings settings) Java APIonCommand
(DurableProducerQueue.State<A> state, DurableProducerQueue.Command<A> command) onCommandBeforeInitialCleanup
(DurableProducerQueue.State<A> state, DurableProducerQueue.Command<A> command) onEvent
(DurableProducerQueue.State<A> state, DurableProducerQueue.Event event)
-
Constructor Details
-
EventSourcedProducerQueue
public EventSourcedProducerQueue(ActorContext<DurableProducerQueue.Command<A>> context, scala.concurrent.duration.FiniteDuration cleanupUnusedAfter)
-
-
Method Details
-
apply
-
apply
public static <A> Behavior<DurableProducerQueue.Command<A>> apply(PersistenceId persistenceId, EventSourcedProducerQueue.Settings settings) -
create
Java API -
create
public static <A> Behavior<DurableProducerQueue.Command<A>> create(PersistenceId persistenceId, EventSourcedProducerQueue.Settings settings) Java API -
onCommand
public Effect<DurableProducerQueue.Event,DurableProducerQueue.State<A>> onCommand(DurableProducerQueue.State<A> state, DurableProducerQueue.Command<A> command) -
onCommandBeforeInitialCleanup
public Effect<DurableProducerQueue.Event,DurableProducerQueue.State<A>> onCommandBeforeInitialCleanup(DurableProducerQueue.State<A> state, DurableProducerQueue.Command<A> command) -
onEvent
public DurableProducerQueue.State<A> onEvent(DurableProducerQueue.State<A> state, DurableProducerQueue.Event event)
-