Merge pull request #28594 from akka/wip-persistence-view-patriknw
remove obsolete PersistenceSettings.view
This commit is contained in:
commit
77e1bfbc1b
4 changed files with 5 additions and 16 deletions
|
|
@ -0,0 +1,3 @@
|
|||
# PersistenceSettings.view
|
||||
ProblemFilters.exclude[DirectMissingMethodProblem]("akka.persistence.PersistenceSettings.view")
|
||||
ProblemFilters.exclude[MissingClassProblem]("akka.persistence.PersistenceSettings$view$")
|
||||
|
|
@ -11,7 +11,7 @@ import scala.collection.immutable
|
|||
/**
|
||||
* INTERNAL API.
|
||||
*
|
||||
* Messages exchanged between persistent actors, views and a journal.
|
||||
* Messages exchanged between persistent actors and a journal.
|
||||
*/
|
||||
private[persistence] object JournalProtocol {
|
||||
|
||||
|
|
|
|||
|
|
@ -26,20 +26,6 @@ import akka.annotation.InternalApi
|
|||
*/
|
||||
final class PersistenceSettings(config: Config) {
|
||||
|
||||
object view {
|
||||
val autoUpdate: Boolean =
|
||||
config.getBoolean("view.auto-update")
|
||||
|
||||
val autoUpdateInterval: FiniteDuration =
|
||||
config.getMillisDuration("view.auto-update-interval")
|
||||
|
||||
val autoUpdateReplayMax: Long =
|
||||
posMax(config.getLong("view.auto-update-replay-max"))
|
||||
|
||||
private def posMax(v: Long) =
|
||||
if (v < 0) Long.MaxValue else v
|
||||
}
|
||||
|
||||
object atLeastOnceDelivery {
|
||||
|
||||
val redeliverInterval: FiniteDuration =
|
||||
|
|
|
|||
|
|
@ -9,7 +9,7 @@ import akka.actor.NoSerializationVerificationNeeded
|
|||
/**
|
||||
* INTERNAL API.
|
||||
*
|
||||
* Messages exchanged between persistent actors, views and a journal/snapshot-store.
|
||||
* Messages exchanged between persistent actors and a journal/snapshot-store.
|
||||
*/
|
||||
private[persistence] object Protocol {
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue