akka.contrib

pattern

package pattern

Visibility
  1. Public
  2. All

Type Members

  1. trait Aggregator extends AnyRef

    The aggregator is to be mixed into an actor for the aggregator behavior.

  2. class ClusterClient extends Actor with ActorLogging

    This actor is intended to be used on an external node that is not member of the cluster.

  3. class ClusterReceptionist extends Actor with ActorLogging

    ClusterClient connects to this actor to retrieve.

  4. class ClusterReceptionistExtension extends Extension

  5. class ClusterSingletonManager extends Actor with FSM[State, Data]

    Manages singleton actor instance among all cluster nodes or a group of nodes tagged with a specific role.

  6. class ClusterSingletonManagerIsStuck extends AkkaException

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

  7. trait ClusterSingletonPropsFactory extends Serializable

    Java API.

  8. class DistributedPubSubExtension extends Extension

  9. class DistributedPubSubMediator extends Actor with ActorLogging

    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.

  10. class ReliableProxy extends Actor with FSM[State, Vector[Message]]

    A ReliableProxy is a means to wrap a remote actor reference in order to obtain certain improved delivery guarantees:

  11. class WorkList[T] extends AnyRef

    Fast, small, and dirty implementation of a linked list that removes transient work entries once they are processed.

Value Members

  1. object ClusterClient

  2. object ClusterReceptionist

  3. object ClusterReceptionistExtension extends ExtensionId[ClusterReceptionistExtension] with ExtensionIdProvider

    Extension that starts ClusterReceptionist and accompanying DistributedPubSubMediator with settings defined in config section akka.contrib.cluster.receptionist.

  4. object ClusterSingletonManager

  5. object DistributedPubSubExtension extends ExtensionId[DistributedPubSubExtension] with ExtensionIdProvider

    Extension that starts a DistributedPubSubMediator actor with settings defined in config section akka.contrib.cluster.pub-sub.

  6. object DistributedPubSubMediator

  7. object ReliableProxy

  8. object WorkList

    Provides the utility methods and constructors to the WorkList class.

Ungrouped