Class EventSourcedProducerQueue.Settings
java.lang.Object
org.apache.pekko.persistence.typed.delivery.EventSourcedProducerQueue.Settings
- Enclosing class:
- EventSourcedProducerQueue<A>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionscala.concurrent.duration.FiniteDurationbooleanJava APIJava APIintscala.concurrent.duration.FiniteDurationinttoString()withCleanupUnusedAfter(Duration newCleanupUnusedAfter) Java APIwithCleanupUnusedAfter(scala.concurrent.duration.FiniteDuration newCleanupUnusedAfter) Scala APIwithDeleteEvents(boolean newDeleteEvents) withKeepNSnapshots(int newKeepNSnapshots) withRestartMaxBackoff(Duration newRestartMaxBackoff) Java APIwithRestartMaxBackoff(scala.concurrent.duration.FiniteDuration newRestartMaxBackoff) Scala APIwithSnapshotEvery(int newSnapshotEvery)
-
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
-
snapshotPluginId
-
withSnapshotEvery
-
withKeepNSnapshots
-
withDeleteEvents
-
withRestartMaxBackoff
public EventSourcedProducerQueue.Settings withRestartMaxBackoff(scala.concurrent.duration.FiniteDuration newRestartMaxBackoff) Scala API -
withRestartMaxBackoff
Java API -
getRestartMaxBackoff
Java API -
withCleanupUnusedAfter
public EventSourcedProducerQueue.Settings withCleanupUnusedAfter(scala.concurrent.duration.FiniteDuration newCleanupUnusedAfter) Scala API -
withCleanupUnusedAfter
Java API -
getCleanupUnusedAfter
Java API -
withJournalPluginId
-
withSnapshotPluginId
-
toString
-