Package akka.contrib.pattern

Interface Summary

Aggregator	The aggregator is to be mixed into an actor for the aggregator behavior.
ClusterSingletonManager.Data	INTERNAL API public due to the with FSM type parameters
ClusterSingletonManager.State	INTERNAL API public due to the with FSM type parameters
DistributedPubSubMediator.Internal$.TopicLike
DistributedPubSubMessage	Marker trait for remote messages with special serializer.
ReliableProxy.State
ReliableProxyDebugLogging	INTERNAL API
ShardCoordinator.Internal$.CoordinatorCommand	Messages sent to the coordinator
ShardCoordinator.Internal$.CoordinatorMessage	Messages sent from the coordinator
ShardCoordinator.Internal$.DomainEvent
ShardCoordinator.ShardAllocationStrategy	Interface of the pluggable shard allocation and rebalancing logic used by the ShardCoordinator.
ShardRegion.MessageExtractor	Java API: Interface of functions to extract entry id, shard id, and the message to send to the entry from an incoming message.
ShardRegion.ShardRegionCommand

Class Summary

ClusterClient	This actor is intended to be used on an external node that is not member of the cluster.
ClusterClient.Internal$	INTERNAL API
ClusterClient.Publish
ClusterClient.Publish$
ClusterClient.Send
ClusterClient.Send$
ClusterClient.SendToAll
ClusterClient.SendToAll$
ClusterClient$
ClusterReceptionist	ClusterClient connects to this actor to retrieve.
ClusterReceptionist.Internal$	INTERNAL API
ClusterReceptionist$
ClusterReceptionistExtension
ClusterReceptionistExtension$	Extension that starts ClusterReceptionist and accompanying DistributedPubSubMediator with settings defined in config section akka.contrib.cluster.receptionist.
ClusterSharding
ClusterSharding$	This extension provides sharding functionality of actors in a cluster.
ClusterShardingGuardian	INTERNAL API.
ClusterShardingGuardian.Start
ClusterShardingGuardian.Start$
ClusterShardingGuardian.Started
ClusterShardingGuardian.Started$
ClusterShardingGuardian$	INTERNAL API.
ClusterSingletonManager	Manages singleton actor instance among all cluster nodes or a group of nodes tagged with a specific role.
ClusterSingletonManager$
ClusterSingletonProxy	The ClusterSingletonProxy works together with the ClusterSingletonManager to provide a distributed proxy to the singleton actor.
ClusterSingletonProxy$
DistributedPubSubExtension
DistributedPubSubExtension$	Extension that starts a DistributedPubSubMediator actor with settings defined in config section akka.contrib.cluster.pub-sub.
DistributedPubSubMediator	This actor manages a registry of actor references and replicates the entries to peer actors among all cluster nodes or a group of nodes tagged with a specific role.
DistributedPubSubMediator.Count$
DistributedPubSubMediator.Internal$	INTERNAL API
DistributedPubSubMediator.Publish
DistributedPubSubMediator.Publish$
DistributedPubSubMediator.Put
DistributedPubSubMediator.Put$
DistributedPubSubMediator.Remove
DistributedPubSubMediator.Remove$
DistributedPubSubMediator.Send
DistributedPubSubMediator.Send$
DistributedPubSubMediator.SendToAll
DistributedPubSubMediator.SendToAll$
DistributedPubSubMediator.Subscribe
DistributedPubSubMediator.Subscribe$
DistributedPubSubMediator.SubscribeAck
DistributedPubSubMediator.SubscribeAck$
DistributedPubSubMediator.Unsubscribe
DistributedPubSubMediator.Unsubscribe$
DistributedPubSubMediator.UnsubscribeAck
DistributedPubSubMediator.UnsubscribeAck$
DistributedPubSubMediator$
ReliableProxy	A ReliableProxy is a means to wrap a remote actor reference in order to obtain certain improved delivery guarantees:
ReliableProxy.Active$
ReliableProxy.Connecting$
ReliableProxy.Idle$
ReliableProxy.Message
ReliableProxy.Message$
ReliableProxy.ProxyTerminated	ProxyTerminated is sent to transition subscribers during postStop.
ReliableProxy.ProxyTerminated$
ReliableProxy.Receiver
ReliableProxy.TargetChanged	TargetChanged is sent to transition subscribers when the initial connection is made the target and when the target ActorRef has changed (for example, the target system crashed and has been restarted).
ReliableProxy.TargetChanged$
ReliableProxy.Unsent
ReliableProxy.Unsent$
ReliableProxy$
ShardCoordinator	Singleton coordinator that decides where to allocate shards.
ShardCoordinator.AbstractShardAllocationStrategy	Java API: Java implementations of custom shard allocation and rebalancing logic used by the ShardCoordinator should extend this abstract class and implement the two methods.
ShardCoordinator.Internal$	INTERNAL API
ShardCoordinator.LeastShardAllocationStrategy	The default implementation of ShardCoordinator.LeastShardAllocationStrategy allocates new shards to the ShardRegion with least number of previously allocated shards.
ShardCoordinator.RebalanceWorker	INTERNAL API.
ShardCoordinator$
ShardCoordinatorSupervisor
ShardCoordinatorSupervisor$
ShardRegion	This actor creates children entry actors on demand for the shards that it is told to be responsible for.
ShardRegion.HandOffStopper	INTERNAL API.
ShardRegion.Passivate	If the state of the entries are persistent you may stop entries that are not used to reduce memory consumption.
ShardRegion.Passivate$
ShardRegion$
WorkList<T>	Fast, small, and dirty implementation of a linked list that removes transient work entries once they are processed.
WorkList.Entry<T>	Singly linked list entry implementation for WorkList.
WorkList$	Provides the utility methods and constructors to the WorkList class.

Exception Summary

ClusterSingletonManagerIsStuck

Thrown when a consistent state can't be determined within the defined retry limits.