akka.cluster.fastfailover

Class FastFailover

java.lang.Object

akka.cluster.fastfailover.FastFailover

All Implemented Interfaces:

akka.actor.Extension

public final class FastFailover
extends java.lang.Object
implements akka.actor.Extension

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FastFailover.Attempt Sent to a fast failover routee to ask it to attempt the operation for the given message.
static class	FastFailover.Attempt$
static class	FastFailover.Fail$ An error should cause the operation to fail.
static class	FastFailover.Failover$ An error should cause the operation to failover.
static interface	FastFailover.FailureDirective A failure directive.
static class	FastFailover.Heartbeat A heartbeat.
static class	FastFailover.Heartbeat$
static interface	FastFailover.MessageExtractor Java API: Interface of functions to extract entity id and the message to send to the entity from an incoming message.
static class	FastFailover.Result The result of an attempt.
static class	FastFailover.Result$

Constructor Summary

Constructors

Constructor and Description
FastFailover(akka.actor.ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
static T	apply(akka.actor.ActorSystem system)
static FastFailover	createExtension(akka.actor.ExtendedActorSystem system)
static boolean	equals(java.lang.Object other)
static scala.PartialFunction<java.lang.Object,scala.Tuple2<java.lang.String,java.lang.Object>>	extractEntityId() Extract entity id function to use with cluster sharding.
static scala.Function1<java.lang.Object,java.lang.String>	extractShardId(int numShards) Extract shard id function to use with cluster sharding.
static FastFailover.Fail$	fail() Java API: An error should cause the operation to fail.
static FastFailover.Failover$	failover() Java API: An error should cause the operation to failover.
static FastFailover	get(akka.actor.ActorSystem system)
static int	hashCode()
static FastFailover$	lookup()
akka.actor.ActorRef	start(java.lang.String actorName, FastFailoverSettings settings, scala.collection.immutable.IndexedSeq<akka.routing.Routee> routees, scala.PartialFunction<java.lang.Object,scala.Tuple2<java.lang.String,java.lang.Object>> extractEntityId, scala.PartialFunction<java.lang.Throwable,FastFailover.FailureDirective> failureStrategy) Start a fast failover actor.
akka.actor.ActorRef	start(java.lang.String actorName, FastFailoverSettings settings, java.lang.Iterable<akka.routing.Routee> routees, FastFailover.MessageExtractor messageExtractor, scala.PartialFunction<java.lang.Throwable,FastFailover.FailureDirective> failureStrategy) Java API: Start a fast failover actor.

Methods inherited from class java.lang.Object

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

Constructor Detail

FastFailover

public FastFailover(akka.actor.ExtendedActorSystem system)

Method Detail

extractEntityId

public static scala.PartialFunction<java.lang.Object,scala.Tuple2<java.lang.String,java.lang.Object>> extractEntityId()

Extract entity id function to use with cluster sharding.

Provided for convenience

Returns:

(undocumented)

extractShardId

public static scala.Function1<java.lang.Object,java.lang.String> extractShardId(int numShards)

Extract shard id function to use with cluster sharding.

Provided for convenience.

Parameters:

numShards - (undocumented)

Returns:

(undocumented)

fail

public static FastFailover.Fail$ fail()

Java API: An error should cause the operation to fail.

Returns:

(undocumented)

failover

public static FastFailover.Failover$ failover()

Java API: An error should cause the operation to failover.

Returns:

(undocumented)

get

public static FastFailover get(akka.actor.ActorSystem system)

lookup

public static FastFailover$ lookup()

createExtension

public static FastFailover createExtension(akka.actor.ExtendedActorSystem system)

apply

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

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object other)

start

public akka.actor.ActorRef start(java.lang.String actorName,
                                 FastFailoverSettings settings,
                                 scala.collection.immutable.IndexedSeq<akka.routing.Routee> routees,
                                 scala.PartialFunction<java.lang.Object,scala.Tuple2<java.lang.String,java.lang.Object>> extractEntityId,
                                 scala.PartialFunction<java.lang.Throwable,FastFailover.FailureDirective> failureStrategy)

Start a fast failover actor.

Parameters:

actorName - The name of the actor.

settings - The fast failover settings for this actor.

routees - The routees.

extractEntityId - The function to extract the entity id from an operation.

failureStrategy - The failure strategy.

Returns:

(undocumented)

start

public akka.actor.ActorRef start(java.lang.String actorName,
                                 FastFailoverSettings settings,
                                 java.lang.Iterable<akka.routing.Routee> routees,
                                 FastFailover.MessageExtractor messageExtractor,
                                 scala.PartialFunction<java.lang.Throwable,FastFailover.FailureDirective> failureStrategy)

Java API: Start a fast failover actor.

Parameters:

actorName - The name of the actor.

settings - The fast failover settings for this actor.

routees - The routees.

messageExtractor - The message extractor.

failureStrategy - The failure strategy.

Returns:

(undocumented)