Package akka.persistence.typed.delivery

Class EventSourcedProducerQueue.Settings

java.lang.Object

akka.persistence.typed.delivery.EventSourcedProducerQueue.Settings

Enclosing class:

EventSourcedProducerQueue<A>

public static final class EventSourcedProducerQueue.Settings
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Settings()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Settings

public Settings()

Method Detail

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 java.lang.String journalPluginId()

snapshotPluginId

public java.lang.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(java.time.Duration newRestartMaxBackoff)

Java API

getRestartMaxBackoff

public java.time.Duration getRestartMaxBackoff()

Java API

withCleanupUnusedAfter

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

Scala API

withCleanupUnusedAfter

public EventSourcedProducerQueue.Settings withCleanupUnusedAfter(java.time.Duration newCleanupUnusedAfter)

Java API

getCleanupUnusedAfter

public java.time.Duration getCleanupUnusedAfter()

Java API

withJournalPluginId

public EventSourcedProducerQueue.Settings withJournalPluginId(java.lang.String id)

withSnapshotPluginId

public EventSourcedProducerQueue.Settings withSnapshotPluginId(java.lang.String id)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object