akka.actor.mailbox.filebased
Class FileBasedMailboxSettings

java.lang.Object
  extended by akka.actor.mailbox.filebased.FileBasedMailboxSettings
All Implemented Interfaces:
DurableMailboxSettings

public class FileBasedMailboxSettings
extends java.lang.Object
implements DurableMailboxSettings


Constructor Summary
FileBasedMailboxSettings(ActorSystem.Settings systemSettings, com.typesafe.config.Config userConfig)
           
 
Method Summary
 scala.concurrent.duration.FiniteDuration CircuitBreakerCallTimeout()
           
 int CircuitBreakerMaxFailures()
           
 scala.concurrent.duration.FiniteDuration CircuitBreakerResetTimeout()
           
 com.typesafe.config.Config config()
          The extracted config section for this mailbox, which is the “name” section (if that exists), falling back to system defaults.
 boolean DiscardOldWhenFull()
           
 boolean KeepJournal()
           
 scala.concurrent.duration.FiniteDuration MaxAge()
           
 int MaxItems()
           
 long MaxItemSize()
           
 int MaxJournalOverflow()
           
 long MaxJournalSize()
           
 long MaxJournalSizeAbsolute()
           
 long MaxMemorySize()
           
 long MaxSize()
           
 java.lang.String name()
          Name of this mailbox type for purposes of configuration scoping.
 java.lang.String QueuePath()
           
 boolean SyncJournal()
           
 ActorSystem.Settings systemSettings()
          A reference to the enclosing actor system.
 com.typesafe.config.Config userConfig()
          A reference to the config section which the user specified for this mailbox’s dispatcher.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.actor.mailbox.DurableMailboxSettings
initialize
 

Constructor Detail

FileBasedMailboxSettings

public FileBasedMailboxSettings(ActorSystem.Settings systemSettings,
                                com.typesafe.config.Config userConfig)
Method Detail

systemSettings

public ActorSystem.Settings systemSettings()
Description copied from interface: DurableMailboxSettings
A reference to the enclosing actor system.

Specified by:
systemSettings in interface DurableMailboxSettings

userConfig

public com.typesafe.config.Config userConfig()
Description copied from interface: DurableMailboxSettings
A reference to the config section which the user specified for this mailbox’s dispatcher.

Specified by:
userConfig in interface DurableMailboxSettings

name

public java.lang.String name()
Description copied from interface: DurableMailboxSettings
Name of this mailbox type for purposes of configuration scoping. Reference defaults go into “akka.actor.mailbox.”.

Specified by:
name in interface DurableMailboxSettings

config

public com.typesafe.config.Config config()
Description copied from interface: DurableMailboxSettings
The extracted config section for this mailbox, which is the “name” section (if that exists), falling back to system defaults. Typical implementation looks like:


 val config = initialize
 

Specified by:
config in interface DurableMailboxSettings

QueuePath

public final java.lang.String QueuePath()

MaxItems

public final int MaxItems()

MaxSize

public final long MaxSize()

MaxItemSize

public final long MaxItemSize()

MaxAge

public final scala.concurrent.duration.FiniteDuration MaxAge()

MaxJournalSize

public final long MaxJournalSize()

MaxMemorySize

public final long MaxMemorySize()

MaxJournalOverflow

public final int MaxJournalOverflow()

MaxJournalSizeAbsolute

public final long MaxJournalSizeAbsolute()

DiscardOldWhenFull

public final boolean DiscardOldWhenFull()

KeepJournal

public final boolean KeepJournal()

SyncJournal

public final boolean SyncJournal()

CircuitBreakerMaxFailures

public final int CircuitBreakerMaxFailures()

CircuitBreakerCallTimeout

public final scala.concurrent.duration.FiniteDuration CircuitBreakerCallTimeout()

CircuitBreakerResetTimeout

public final scala.concurrent.duration.FiniteDuration CircuitBreakerResetTimeout()