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

Class EventSourcedProducerQueue.Settings

java.lang.Object

org.apache.pekko.persistence.typed.delivery.EventSourcedProducerQueue.Settings

Enclosing class:

EventSourcedProducerQueue<A>

public static final class EventSourcedProducerQueue.Settings
extends Object

Constructor Summary

Constructors

Constructor	Description
Settings()

Method Summary

Modifier and Type	Method	Description
scala.concurrent.duration.FiniteDuration	cleanupUnusedAfter()
boolean	deleteEvents()
Duration	getCleanupUnusedAfter()	Java API
Duration	getRestartMaxBackoff()	Java API
String	journalPluginId()
int	keepNSnapshots()
scala.concurrent.duration.FiniteDuration	restartMaxBackoff()
int	snapshotEvery()
String	snapshotPluginId()
String	toString()
EventSourcedProducerQueue.Settings	withCleanupUnusedAfter(Duration newCleanupUnusedAfter)	Java API
EventSourcedProducerQueue.Settings	withCleanupUnusedAfter(scala.concurrent.duration.FiniteDuration newCleanupUnusedAfter)	Scala API
EventSourcedProducerQueue.Settings	withDeleteEvents(boolean newDeleteEvents)
EventSourcedProducerQueue.Settings	withJournalPluginId(String id)
EventSourcedProducerQueue.Settings	withKeepNSnapshots(int newKeepNSnapshots)
EventSourcedProducerQueue.Settings	withRestartMaxBackoff(Duration newRestartMaxBackoff)	Java API
EventSourcedProducerQueue.Settings	withRestartMaxBackoff(scala.concurrent.duration.FiniteDuration newRestartMaxBackoff)	Scala API
EventSourcedProducerQueue.Settings	withSnapshotEvery(int newSnapshotEvery)
EventSourcedProducerQueue.Settings	withSnapshotPluginId(String id)

Methods inherited from class java.lang.Object

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

Constructor Details

Settings

public Settings()

Method Details

restartMaxBackoff

public scala.concurrent.duration.FiniteDuration restartMaxBackoff()

snapshotEvery

public int snapshotEvery()

keepNSnapshots

public int keepNSnapshots()

deleteEvents

public boolean deleteEvents()

cleanupUnusedAfter

public scala.concurrent.duration.FiniteDuration cleanupUnusedAfter()

journalPluginId

public String journalPluginId()

snapshotPluginId

public String snapshotPluginId()

withSnapshotEvery

public EventSourcedProducerQueue.Settings withSnapshotEvery(int newSnapshotEvery)

withKeepNSnapshots

public EventSourcedProducerQueue.Settings withKeepNSnapshots(int newKeepNSnapshots)

withDeleteEvents

public EventSourcedProducerQueue.Settings withDeleteEvents(boolean newDeleteEvents)

withRestartMaxBackoff

public EventSourcedProducerQueue.Settings withRestartMaxBackoff(scala.concurrent.duration.FiniteDuration newRestartMaxBackoff)

Scala API

withRestartMaxBackoff

public EventSourcedProducerQueue.Settings withRestartMaxBackoff(Duration newRestartMaxBackoff)

Java API

getRestartMaxBackoff

public Duration getRestartMaxBackoff()

Java API

withCleanupUnusedAfter

public EventSourcedProducerQueue.Settings withCleanupUnusedAfter(scala.concurrent.duration.FiniteDuration newCleanupUnusedAfter)

Scala API

withCleanupUnusedAfter

public EventSourcedProducerQueue.Settings withCleanupUnusedAfter(Duration newCleanupUnusedAfter)

Java API

getCleanupUnusedAfter

public Duration getCleanupUnusedAfter()

Java API

withJournalPluginId

public EventSourcedProducerQueue.Settings withJournalPluginId(String id)

withSnapshotPluginId

public EventSourcedProducerQueue.Settings withSnapshotPluginId(String id)

toString

public String toString()

Overrides:

toString in class Object