akka.cluster.fastfailover

Class FastFailoverSettings

java.lang.Object

akka.cluster.fastfailover.FastFailoverSettings

public final class FastFailoverSettings
extends java.lang.Object

Fast failover configuration.

param: heartbeatInterval The interval at which to send heartbeats. Generally should be about half of the timeout. param: heartbeatTimeout The time to timeout if no heartbeat is received. param: attemptTimeout The maximum time to allow a single attempt of the operation to take. param: operationTimeout The maximum amount of time that the operation should take in total, after which point the operation will not attempt again and will simply fail. param: maxFailovers The maximum number of times that failover should be attempted. If more than the number of failover groups, this means that failover may be attempted on groups that have already previously failed.

Constructor Summary

Constructors

Constructor and Description
FastFailoverSettings(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration heartbeatTimeout, scala.concurrent.duration.FiniteDuration attemptTimeout, scala.concurrent.duration.FiniteDuration operationTimeout, int maxFailovers)

Method Summary

Modifier and Type	Method and Description
static FastFailoverSettings	apply(akka.actor.ActorSystem system) Create settings from the default configuration akka.cluster.fast-failover.
static FastFailoverSettings	apply(com.typesafe.config.Config config) Create settings from a configuration with the same layout as the default configuration akka.cluster.fast-failover.
scala.concurrent.duration.FiniteDuration	attemptTimeout()
static FastFailoverSettings	create(akka.actor.ActorSystem system) Java API: Create settings from the default configuration akka.cluster.fast-failover.
static FastFailoverSettings	create(com.typesafe.config.Config config) Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.fast-failover.
scala.concurrent.duration.FiniteDuration	heartbeatInterval()
scala.concurrent.duration.FiniteDuration	heartbeatTimeout()
int	maxFailovers()
scala.concurrent.duration.FiniteDuration	operationTimeout()
FastFailoverSettings	withAttemptTimeout(scala.concurrent.duration.FiniteDuration attemptTimeout)
FastFailoverSettings	withHeartbeatInterval(scala.concurrent.duration.FiniteDuration heartbeatInterval)
FastFailoverSettings	withHeartbeatTimeout(scala.concurrent.duration.FiniteDuration heartbeatTimeout)
FastFailoverSettings	withMaxFailovers(int maxFailovers)
FastFailoverSettings	withOperationTimeout(scala.concurrent.duration.FiniteDuration operationTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

FastFailoverSettings

public FastFailoverSettings(scala.concurrent.duration.FiniteDuration heartbeatInterval,
                            scala.concurrent.duration.FiniteDuration heartbeatTimeout,
                            scala.concurrent.duration.FiniteDuration attemptTimeout,
                            scala.concurrent.duration.FiniteDuration operationTimeout,
                            int maxFailovers)

Method Detail

apply

public static FastFailoverSettings apply(akka.actor.ActorSystem system)

Create settings from the default configuration akka.cluster.fast-failover.

Parameters:

system - (undocumented)

Returns:

(undocumented)

apply

public static FastFailoverSettings apply(com.typesafe.config.Config config)

Create settings from a configuration with the same layout as the default configuration akka.cluster.fast-failover.

Parameters:

config - (undocumented)

Returns:

(undocumented)

create

public static FastFailoverSettings create(akka.actor.ActorSystem system)

Java API: Create settings from the default configuration akka.cluster.fast-failover.

Parameters:

system - (undocumented)

Returns:

(undocumented)

create

public static FastFailoverSettings create(com.typesafe.config.Config config)

Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.fast-failover.

Parameters:

config - (undocumented)

Returns:

(undocumented)

heartbeatInterval

public scala.concurrent.duration.FiniteDuration heartbeatInterval()

heartbeatTimeout

public scala.concurrent.duration.FiniteDuration heartbeatTimeout()

attemptTimeout

public scala.concurrent.duration.FiniteDuration attemptTimeout()

operationTimeout

public scala.concurrent.duration.FiniteDuration operationTimeout()

maxFailovers

public int maxFailovers()

withHeartbeatInterval

public FastFailoverSettings withHeartbeatInterval(scala.concurrent.duration.FiniteDuration heartbeatInterval)

withHeartbeatTimeout

public FastFailoverSettings withHeartbeatTimeout(scala.concurrent.duration.FiniteDuration heartbeatTimeout)

withAttemptTimeout

public FastFailoverSettings withAttemptTimeout(scala.concurrent.duration.FiniteDuration attemptTimeout)

withOperationTimeout

public FastFailoverSettings withOperationTimeout(scala.concurrent.duration.FiniteDuration operationTimeout)

withMaxFailovers

public FastFailoverSettings withMaxFailovers(int maxFailovers)