Package org.apache.pekko.persistence.typed.delivery

Class EventSourcedProducerQueue<A>

java.lang.Object

org.apache.pekko.persistence.typed.delivery.EventSourcedProducerQueue<A>

public class EventSourcedProducerQueue<A>
extends Object

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	EventSourcedProducerQueue.Settings
static class	EventSourcedProducerQueue.Settings$

Constructor Summary

Constructors

Constructor	Description
EventSourcedProducerQueue(ActorContext<DurableProducerQueue.Command<A>> context, scala.concurrent.duration.FiniteDuration cleanupUnusedAfter)

Method Summary

Modifier and Type	Method	Description
static <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 API
static <A> Behavior<DurableProducerQueue.Command<A>>	create(PersistenceId persistenceId, EventSourcedProducerQueue.Settings settings)	Java API
Effect<DurableProducerQueue.Event,DurableProducerQueue.State<A>>	onCommand(DurableProducerQueue.State<A> state, DurableProducerQueue.Command<A> command)
Effect<DurableProducerQueue.Event,DurableProducerQueue.State<A>>	onCommandBeforeInitialCleanup(DurableProducerQueue.State<A> state, DurableProducerQueue.Command<A> command)
DurableProducerQueue.State<A>	onEvent(DurableProducerQueue.State<A> state, DurableProducerQueue.Event event)

Methods inherited from class java.lang.Object

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

Constructor Details

EventSourcedProducerQueue

public EventSourcedProducerQueue(ActorContext<DurableProducerQueue.Command<A>> context,
 scala.concurrent.duration.FiniteDuration cleanupUnusedAfter)

Method Details

apply

public static <A>
Behavior<DurableProducerQueue.Command<A>> apply(PersistenceId persistenceId)

apply

public static <A>
Behavior<DurableProducerQueue.Command<A>> apply(PersistenceId persistenceId,
 EventSourcedProducerQueue.Settings settings)

create

public static <A>
Behavior<DurableProducerQueue.Command<A>> create(PersistenceId persistenceId)

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)