| Name | Description | Type | Package | Framework |
| AbstractActor | Java API: compatible with lambda expressions Actor base class that should be extended to create Java actors that use lambdas. | Class | akka.actor | Akka |
|
| AbstractActor$ | Java API: compatible with lambda expressions This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing. | Class | akka.actor | Akka |
|
| AbstractActorContext | AbstractActorContext is the AbstractActor equivalent of ActorContext, containing the Java API | Interface | akka.actor | Akka |
|
| AbstractActorWithStash | Java API: compatible with lambda expressions Actor base class that should be extended to create an actor with a stash. | Class | akka.actor | Akka |
|
| AbstractActorWithUnboundedStash | Java API: compatible with lambda expressions Actor base class with Stash that enforces an unbounded deque for the actor. | Class | akka.actor | Akka |
|
| AbstractActorWithUnrestrictedStash | Java API: compatible with lambda expressions Actor base class with Stash that does not enforce any mailbox type. | Class | akka.actor | Akka |
|
| AbstractBoundedNodeQueue | Lock-free bounded non-blocking multiple-producer single-consumer queue based on the works of: Andriy Plokhotnuyk (https://github. | Class | akka.dispatch | Akka |
|
| AbstractEventsByPersistenceIdPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| AbstractEventsByTagPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| AbstractExtensionId | | Class | akka.actor | Akka |
|
| AbstractFSM | Java API: compatible with lambda expressions Finite State Machine actor abstract base class. | Class | akka.actor | Akka |
|
| AbstractFSM$ | Java API: compatible with lambda expressions This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing. | Class | akka.actor | Akka |
|
| AbstractFSMWithStash | Java API: compatible with lambda expressions Finite State Machine actor abstract base class with Stash support. | Class | akka.actor | Akka |
|
| AbstractLoggingActor | Java API: compatible with lambda expressions Actor base class that mixes in logging into the Actor. | Class | akka.actor | Akka |
|
| AbstractLoggingFSM | Java API: compatible with lambda expressions Finite State Machine actor abstract base class. | Class | akka.actor | Akka |
|
| AbstractMessage | A partial implementation of the Message interface which implements as many methods of that interface as possible in terms of other methods. | Class | akka.protobuf | Akka |
|
| AbstractMessageLite | A partial implementation of the MessageLite interface which implements as many methods of that interface as possible in terms of other | Class | akka.protobuf | Akka |
|
| AbstractNodeQueue | Lock-free MPSC linked queue implementation based on Dmitriy Vyukov's non-intrusive MPSC queue: http://www. | Class | akka.dispatch | Akka |
|
| AbstractParser | A partial implementation of the Parser interface which implements as many methods of that interface as possible in terms of other methods. | Class | akka.protobuf | Akka |
|
| AbstractPersistentActor | Java API: an persistent actor - can be used to implement command or event sourcing. | Class | akka.persistence | Akka |
|
| AbstractPersistentActorWithAtLeastOnceDelivery | Java API compatible with lambda expressions Use this class instead of UntypedPersistentActor to send messages | Class | akka.persistence | Akka |
|
| AbstractPersistentFSM | Java API: compatible with lambda expressions Persistent Finite State Machine actor abstract base class. | Class | akka.persistence.fsm | Akka |
|
| AbstractPersistentFSMBase | Java API: compatible with lambda expressions Finite State Machine actor abstract base class. | Class | akka.persistence.fsm | Akka |
|
| AbstractPersistentFSMBase$ | Java API: compatible with lambda expressions This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing. | Class | akka.persistence.fsm | Akka |
|
| AbstractPersistentLoggingFSM | Java API: compatible with lambda expressions Persistent Finite State Machine actor abstract base class with FSM Logging | Class | akka.persistence.fsm | Akka |
|
| AbstractPersistentView | Java API: compatible with lambda expressions (to be used with ReceiveBuilder)See Also:PersistentView | Class | akka.persistence | Akka |
|
| AbstractProps | Java API: Factory for Props instances. | Interface | akka.actor | Akka |
|
| AbstractReplicatedData | Java API: Interface for implementing a ReplicatedData in Java. | Class | akka.cluster.ddata | Akka |
|
| AbstractScheduler | An Akka scheduler service. | Class | akka.actor | Akka |
|
| AbstractSchedulerBase | | Class | akka.actor | Akka |
|
| AbstractSerializationSupport | | Class | akka.cluster.ddata.protobuf | Akka |
|
| AbstractTransportAdapter | | Class | akka.remote.transport | Akka |
|
| AbstractTransportAdapterHandle | | Class | akka.remote.transport | Akka |
|
| Ack | Positive acknowledgement message (used for application-acknowledged message receipts). | Class | akka.camel | Akka |
|
| Ack | Class representing an acknowledgement with selective negative acknowledgements. | Class | akka.remote | Akka |
|
| Ack$ | Positive acknowledgement message (used for application-acknowledged message receipts). | Class | akka.camel | Akka |
|
| Ack$ | | Class | akka.remote | Akka |
|
| AckedReceiveBuffer | buffer works together with a AckedSendBuffer on the sender() side. | Class | akka.remote | Akka |
|
| AckedReceiveBuffer$ | | Class | akka.remote | Akka |
|
| AckedSendBuffer | when an ack is received. | Class | akka.remote | Akka |
|
| AckedSendBuffer$ | | Class | akka.remote | Akka |
|
| Activation | Activation trait that can be used to wait on activation or de-activation of Camel endpoints. | Interface | akka.camel | Akka |
|
| ActivationProtocol | | Class | akka.camel.internal | Akka |
|
| ActivationProtocol$ | | Class | akka.camel.internal | Akka |
|
| ActivationTracker | An actor that tracks activation and de-activation of endpoints. | Class | akka.camel.internal | Akka |
|
| Actor | Actor base trait that should be extended by or mixed to create an Actor with the semantics of the 'Actor Model': http://en. | Interface | akka.actor | Akka |
|
| Actor$ | | Class | akka.actor | Akka |
|
| ActorActivationException | Thrown by the registrars to indicate that the actor could not be activated. | Class | akka.camel.internal | Akka |
|
| ActorAdapter | INTERNAL API. | Class | akka.typed | Akka |
|
| ActorCell | Everything in here is completely Akka PRIVATE. | Class | akka.actor | Akka |
|
| ActorCell$ | Everything in here is completely Akka PRIVATE. | Class | akka.actor | Akka |
|
| ActorClassification | | Interface | akka.event | Akka |
|
| ActorClassificationUnsubscriber | Watches all actors which subscribe on the given event stream, and unsubscribes them from it when they are Terminated. | Class | akka.event | Akka |
|
| ActorClassificationUnsubscriber$ | Provides factory for ActorClassificationUnsubscriber actors with **unique names**. | Class | akka.event | Akka |
|
| ActorComponent | Creates Camel Endpoints that send messages to Consumer actors through an ActorProducer. | Class | akka.camel.internal.component | Akka |
|
| ActorContext | The actor context - the view of the actor cell from the actor. | Interface | akka.actor | Akka |
|
| ActorContext | An Actor is given by the combination of a Behavior and a context in which this behavior is executed. | Interface | akka.typed | Akka |
|
| ActorContextAdapter | INTERNAL API. | Class | akka.typed | Akka |
|
| ActorDeActivationException | Thrown by registrars to indicate that the actor could not be de-activated. | Class | akka.camel.internal | Akka |
|
| ActorDSL | This object contains elements which make writing actors and related code more concise, e. | Class | akka.actor | Akka |
|
| ActorDSL$ | This object contains elements which make writing actors and related code more concise, e. | Class | akka.actor | Akka |
|
| ActorEndpoint | Does what an endpoint does, creates consumers and producers for the component. | Class | akka.camel.internal.component | Akka |
|
| ActorEndpointConfig | Configures the ActorEndpoint. | Interface | akka.camel.internal.component | Akka |
|
| ActorEndpointPath | An endpoint to an ActorRef param: actorPath the String representation of the path to the actor | Class | akka.camel.internal.component | Akka |
|
| ActorEndpointPath$ | Companion of ActorEndpointPathSee Also:Serialized Form | Class | akka.camel.internal.component | Akka |
|
| ActorEventBus | | Interface | akka.event | Akka |
|
| ActorEventBus | Java API: See documentation for ActorClassification An EventBus where the Subscribers are ActorRefs and the Classifier is ActorRef | Class | akka.event.japi | Akka |
|
| ActorIdentity | Reply to Identify. | Class | akka.actor | Akka |
|
| ActorIdentity$ | | Class | akka.actor | Akka |
|
| ActorInitializationException | An ActorInitializationException is thrown when the initialization logic for an Actor fails. | Class | akka.actor | Akka |
|
| ActorInitializationException$ | | Class | akka.actor | Akka |
|
| ActorInterruptedException | When an InterruptedException is thrown inside an Actor, it is wrapped as an ActorInterruptedException as to avoid cascading interrupts to other threads than the originally interrupted one. | Class | akka.actor | Akka |
|
| ActorKilledException | ActorKilledException is thrown when an Actor receives the Kill messageSee Also:Serialized Form | Class | akka.actor | Akka |
|
| ActorKilledException$ | | Class | akka.actor | Akka |
|
| ActorLogging | Scala API: Mix in ActorLogging into your Actor to easily obtain a reference to a logger, which is available under the name "log". | Interface | akka.actor | Akka |
|
| ActorNotFound | When ActorSelection. | Class | akka.actor | Akka |
|
| ActorNotFound$ | | Class | akka.actor | Akka |
|
| ActorNotRegisteredException | Thrown to indicate that the actor referenced by an endpoint URI cannot be found in the actor system. | Class | akka.camel | Akka |
|
| ActorPath | Actor path is a unique path to an actor that shows the creation path up through the actor tree to the root actor. | Interface | akka.actor | Akka |
|
| ActorPath$ | | Class | akka.actor | Akka |
|
| ActorPathExtractor | | Class | akka.actor | Akka |
|
| ActorPathExtractor$ | | Class | akka.actor | Akka |
|
| ActorPaths | | Class | akka.actor | Akka |
|
| ActorPaths$ | | Class | akka.actor | Akka |
|
| ActorProducer | Sends the in-message of an exchange to an untyped actor, identified by an ActorEndpointSee Also:ActorComponent, | Class | akka.camel.internal.component | Akka |
|
| ActorRef | Immutable and serializable handle to an actor, which may or may not reside on the local host or inside the same ActorSystem. | Class | akka.actor | Akka |
|
| ActorRef | An ActorRef is the identity or address of an Actor instance. | Class | akka.typed | Akka |
|
| ActorRef$ | | Class | akka.actor | Akka |
|
| ActorRef$ | | Class | akka.typed | Akka |
|
| ActorRefFactory | Interface implemented by ActorSystem and ActorContext, the only two places from which you can get fresh actors. | Interface | akka.actor | Akka |
|
| ActorRefProvider | Interface for all ActorRef providers to implement. | Interface | akka.actor | Akka |
|
| ActorRefRoutee | Routee that sends the messages to an ActorRef. | Class | akka.routing | Akka |
|
| ActorRefRoutee$ | | Class | akka.routing | Akka |
|
| ActorRefScope | All ActorRefs have a scope which describes where they live. | Interface | akka.actor | Akka |
|
| ActorRefWithCell | Common trait of all actor refs which actually have a Cell, most notably LocalActorRef and RepointableActorRef. | Class | akka.actor | Akka |
|
| ActorRouteDefinition | Wraps a ProcessorDefinition. | Class | akka.camel | Akka |
|
| ActorSelection | An ActorSelection is a logical view of a section of an ActorSystem's tree of Actors, allowing for broadcasting of messages to that section. | Class | akka.actor | Akka |
|
| ActorSelection$ | An ActorSelection is a logical view of a section of an ActorSystem's tree of Actors, allowing for broadcasting of messages to that section. | Class | akka.actor | Akka |
|
| ActorSelectionMessage | ActorRefFactory. | Class | akka.actor | Akka |
|
| ActorSelectionMessage$ | | Class | akka.actor | Akka |
|
| ActorSelectionRoutee | Routee that sends the messages to an ActorSelection. | Class | akka.routing | Akka |
|
| ActorSelectionRoutee$ | | Class | akka.routing | Akka |
|
| ActorSystem | An actor system is a hierarchical group of actors which share common configuration, e. | Class | akka.actor | Akka |
|
| ActorSystem | An ActorSystem is home to a hierarchy of Actors. | Class | akka.typed | Akka |
|
| ActorSystem$ | | Class | akka.actor | Akka |
|
| ActorSystem$ | | Class | akka.typed | Akka |
|
| ActorSystemActivator | Abstract bundle activator implementation to bootstrap and configure an actor system in an OSGi environment. | Class | akka.osgi | Akka |
|
| ActorSystemImpl | | Class | akka.actor | Akka |
|
| ActorTransportAdapter | | Class | akka.remote.transport | Akka |
|
| ActorTransportAdapter$ | | Class | akka.remote.transport | Akka |
|
| ActorTransportAdapterManager | | Class | akka.remote.transport | Akka |
|
| AdaptiveLoadBalancingGroup | A router group that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.metrics | Akka |
|
| AdaptiveLoadBalancingGroup | A router group that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.routing | Akka |
|
| AdaptiveLoadBalancingGroup$ | | Class | akka.cluster.metrics | Akka |
|
| AdaptiveLoadBalancingGroup$ | | Class | akka.cluster.routing | Akka |
|
| AdaptiveLoadBalancingMetricsListener | Subscribe to ClusterMetricsEvents and update routing logic depending on the events. | Class | akka.cluster.metrics | Akka |
|
| AdaptiveLoadBalancingMetricsListener | | Class | akka.cluster.routing | Akka |
|
| AdaptiveLoadBalancingPool | A router pool that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.metrics | Akka |
|
| AdaptiveLoadBalancingPool | A router pool that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.routing | Akka |
|
| AdaptiveLoadBalancingPool$ | | Class | akka.cluster.metrics | Akka |
|
| AdaptiveLoadBalancingPool$ | | Class | akka.cluster.routing | Akka |
|
| AdaptiveLoadBalancingRoutingLogic | Load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.metrics | Akka |
|
| AdaptiveLoadBalancingRoutingLogic | Load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.routing | Akka |
|
| AdaptiveLoadBalancingRoutingLogic$ | | Class | akka.cluster.metrics | Akka |
|
| AdaptiveLoadBalancingRoutingLogic$ | | Class | akka.cluster.routing | Akka |
|
| Address | The address specifies the physical location under which an Actor can be reached. | Class | akka.actor | Akka |
|
| Address$ | | Class | akka.actor | Akka |
|
| AddressFromURIString | This object serves as extractor for Scala and as address parser for Java. | Class | akka.actor | Akka |
|
| AddressFromURIString$ | This object serves as extractor for Scala and as address parser for Java. | Class | akka.actor | Akka |
|
| AddressReply | | Class | akka.remote.testconductor | Akka |
|
| AddressReply$ | | Class | akka.remote.testconductor | Akka |
|
| AddressTerminated | Used for remote death watch. | Class | akka.actor | Akka |
|
| AddressTerminated$ | | Class | akka.actor | Akka |
|
| AddressTerminatedTopic | | Class | akka.event | Akka |
|
| AddressTerminatedTopic$ | Watchers of remote actor references register themselves as subscribers of AddressTerminated notifications. | Class | akka.event | Akka |
|
| AddressUidExtension | | Class | akka.remote | Akka |
|
| AddressUidExtension$ | Extension that holds a uid that is assigned as a random Int. | Class | akka.remote | Akka |
|
| AddressUrlEncoder | | Class | akka.remote | Akka |
|
| AddressUrlEncoder$ | | Class | akka.remote | Akka |
|
| AddRoutee | Add a routee by sending this message to the router. | Class | akka.routing | Akka |
|
| AddRoutee$ | | Class | akka.routing | Akka |
|
| AdjustPoolSize | Increase or decrease the number of routees in a Pool. | Class | akka.routing | Akka |
|
| AdjustPoolSize$ | | Class | akka.routing | Akka |
|
| AES128CounterInetRNG | This class is a wrapper around the 128-bit AESCounterRNG algorithm provided by http://maths. | Class | akka.remote.security.provider | Akka |
|
| AES128CounterSecureRNG | This class is a wrapper around the 128-bit AESCounterRNG algorithm provided by http://maths. | Class | akka.remote.security.provider | Akka |
|
| AES256CounterInetRNG | This class is a wrapper around the 256-bit AESCounterRNG algorithm provided by http://maths. | Class | akka.remote.security.provider | Akka |
|
| AES256CounterSecureRNG | This class is a wrapper around the 256-bit AESCounterRNG algorithm provided by http://maths. | Class | akka.remote.security.provider | Akka |
|
| Agent | The Agent class was inspired by agents in Clojure. | Class | akka.agent | Akka |
|
| Agent$ | | Class | akka.agent | Akka |
|
| Aggregator | The aggregator is to be mixed into an actor for the aggregator behavior. | Interface | akka.contrib.pattern | Akka |
|
| AkkaCamelException | An exception indicating that the exchange to the camel endpoint failed. | Class | akka.camel | Akka |
|
| AkkaException | Akka base Exception. | Class | akka | Akka |
|
| AkkaPduCodec | A Codec that is able to convert Akka PDUs (Protocol Data Units) from and to ByteStrings. | Interface | akka.remote.transport | Akka |
|
| AkkaPduCodec$ | Companion object of the AkkaPduCodec trait. | Class | akka.remote.transport | Akka |
|
| AkkaPduProtobufCodec | | Class | akka.remote.transport | Akka |
|
| AkkaPduProtobufCodec$ | | Class | akka.remote.transport | Akka |
|
| AkkaProtocolException | | Class | akka.remote.transport | Akka |
|
| AkkaProtocolHandle | | Class | akka.remote.transport | Akka |
|
| AkkaProtocolManager | | Class | akka.remote.transport | Akka |
|
| AkkaProtocolSettings | | Class | akka.remote.transport | Akka |
|
| AkkaProtocolTransport | Features provided by this transport are: - Soft-state associations via the use of heartbeats and failure detectors | Class | akka.remote.transport | Akka |
|
| AkkaProtocolTransport$ | | Class | akka.remote.transport | Akka |
|
| AkkaProvider | A provider that for AES128CounterRNGFast, a cryptographically secure random number generator through SecureRandomSee Also:Serialized Form | Class | akka.remote.security.provider | Akka |
|
| AkkaProvider$ | A provider that for AES128CounterRNGFast, a cryptographically secure random number generator through SecureRandomSee Also:Serialized Form | Class | akka.remote.security.provider | Akka |
|
| AllDeadLetters | Subscribe to this class to be notified about all DeadLetters (also the suppressed ones). | Interface | akka.actor | Akka |
|
| AllForOneStrategy | Applies the fault handling Directive (Resume, Restart, Stop) specified in the Decider to all children when one fails, as opposed to OneForOneStrategy that applies | Class | akka.actor | Akka |
|
| AllForOneStrategy$ | | Class | akka.actor | Akka |
|
| AllPersistenceIdsPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| AllPersistenceIdsPublisher$ | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| AllPersistenceIdsQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
|
| AllPersistenceIdsQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
|
| ArgsReflectConstructor | | Class | akka.actor | Akka |
|
| AskableActorRef | | Class | akka.pattern | Akka |
|
| AskableActorRef$ | | Class | akka.pattern | Akka |
|
| AskableActorSelection | | Class | akka.pattern | Akka |
|
| AskableActorSelection$ | | Class | akka.pattern | Akka |
|
| AskPattern | | Class | akka.typed | Akka |
|
| AskPattern$ | | Class | akka.typed | Akka |
|
| AskPromiseRef | | Class | akka.pattern | Akka |
|
| AskPromiseRef$ | | Class | akka.pattern | Akka |
|
| AskSupport | This object contains implementation details of the “ask” pattern. | Interface | akka.pattern | Akka |
|
| AskTimeoutException | This is what is used to complete a Future that is returned from an ask/? call,See Also:Serialized Form | Class | akka.pattern | Akka |
|
| AssociatedEvent | | Class | akka.remote | Akka |
|
| AssociatedEvent$ | | Class | akka.remote | Akka |
|
| AssociationErrorEvent | | Class | akka.remote | Akka |
|
| AssociationErrorEvent$ | | Class | akka.remote | Akka |
|
| AssociationEvent | | Interface | akka.remote | Akka |
|
| AssociationHandle | An SPI layer for abstracting over logical links (associations) created by a Transport. | Interface | akka.remote.transport | Akka |
|
| AssociationHandle$ | | Class | akka.remote.transport | Akka |
|
| AssociationRegistry | | Class | akka.remote.transport | Akka |
|
| AssociationRegistry$ | | Class | akka.remote.transport | Akka |
|
| AsyncRecovery | Asynchronous message replay and sequence number recovery interface. | Interface | akka.persistence.journal | Akka |
|
| AsyncRecovery | Java API: asynchronous message replay and sequence number recovery interface. | Class | akka.persistence.journal.japi | Akka |
|
| AsyncReplayTimeoutException | Thrown if replay inactivity exceeds a specified timeout. | Class | akka.persistence.journal | Akka |
|
| AsyncWriteJournal | Abstract journal, optimized for asynchronous, non-blocking writes. | Interface | akka.persistence.journal | Akka |
|
| AsyncWriteJournal | Java API: abstract journal, optimized for asynchronous, non-blocking writes. | Class | akka.persistence.journal.japi | Akka |
|
| AsyncWriteJournal$ | | Class | akka.persistence.journal | Akka |
|
| AsyncWriteProxy | A journal that delegates actual storage to a target actor. | Interface | akka.persistence.journal | Akka |
|
| AsyncWriteProxy$ | | Class | akka.persistence.journal | Akka |
|
| AsyncWriteTarget | | Class | akka.persistence.journal | Akka |
|
| AsyncWriteTarget$ | | Class | akka.persistence.journal | Akka |
|
| AtLeastOnceDelivery | Mix-in this trait with your PersistentActor to send messages with at-least-once delivery semantics to destinations. | Interface | akka.persistence | Akka |
|
| AtLeastOnceDelivery$ | | Class | akka.persistence | Akka |
|
| AtLeastOnceDeliveryLike | | Interface | akka.persistence | Akka |
|
| AtomicWrite | | Class | akka.persistence | Akka |
|
| AtomicWrite$ | | Class | akka.persistence | Akka |
|
| AutoDown | An unreachable member will be downed by this actor if it remains unreachable for the specified duration and this actor is running on the leader node in the | Class | akka.cluster | Akka |
|
| AutoDown$ | | Class | akka.cluster | Akka |
|
| AutoDownBase | The implementation is split into two classes AutoDown and AutoDownBase to be able to unit test the logic without running cluster. | Class | akka.cluster | Akka |
|
| AwaitActivation | A request message to the ActivationTracker for the status of activation. | Class | akka.camel.internal | Akka |
|
| AwaitActivation$ | | Class | akka.camel.internal | Akka |
|
| AwaitDeActivation | A request message to the ActivationTracker for the status of de-activation. | Class | akka.camel.internal | Akka |
|
| AwaitDeActivation$ | | Class | akka.camel.internal | Akka |
|
| BackoffSupervisor | This actor can be used to supervise a child actor and start it again after a back-off duration if the child actor is stopped. | Class | akka.pattern | Akka |
|
| BackoffSupervisor$ | | Class | akka.pattern | Akka |
|
| BalancingDispatcher | An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors. | Class | akka.dispatch | Akka |
|
| BalancingDispatcherConfigurator | Configurator for creating BalancingDispatcher. | Class | akka.dispatch | Akka |
|
| BalancingDispatcherConfigurator$ | | Class | akka.dispatch | Akka |
|
| BalancingPool | A router pool that will try to redistribute work from busy routees to idle routees. | Class | akka.routing | Akka |
|
| BalancingPool$ | | Class | akka.routing | Akka |
|
| BalancingPoolDeploy | Can't be in the BalancingPool companion for binary compatibility reasons. | Class | akka.routing | Akka |
|
| BalancingPoolDeploy$ | Can't be in the BalancingPool companion for binary compatibility reasons. | Class | akka.routing | Akka |
|
| BalancingRoutingLogic | Selects the first routee, balancing will be done by the dispatcher. | Class | akka.routing | Akka |
|
| BalancingRoutingLogic$ | | Class | akka.routing | Akka |
|
| BarrierCoordinator | This barrier coordinator gets informed of players connecting (NodeInfo), players being deliberately removed (RemoveClient) or failing (ClientDisconnected) | Class | akka.remote.testconductor | Akka |
|
| BarrierCoordinator$ | | Class | akka.remote.testconductor | Akka |
|
| BarrierResult | | Class | akka.remote.testconductor | Akka |
|
| BarrierResult$ | | Class | akka.remote.testconductor | Akka |
|
| BaseSerializer | Base serializer trait with serialization identifiers configuration contract, when globally unique serialization identifier is configured in the reference. | Interface | akka.serialization | Akka |
|
| Batchable | | Interface | akka.dispatch | Akka |
|
| BatchingExecutor | Mixin trait for an Executor which groups multiple nested Runnable. | Interface | akka.dispatch | Akka |
|
| Behavior | The behavior of an actor defines how it reacts to the messages that it receives. | Class | akka.typed | Akka |
|
| Behavior$ | | Class | akka.typed | Akka |
|
| BlockingRpcChannel | Abstract interface for a blocking RPC channel. | Interface | akka.protobuf | Akka |
|
| BlockingService | Blocking equivalent to Service. | Interface | akka.protobuf | Akka |
|
| Bootable | To use the microkernel at least one 'boot class' needs to be specified. | Interface | akka.kernel | Akka |
|
| BoundAddressesExtension | | Class | akka.remote | Akka |
|
| BoundAddressesExtension$ | Extension provides access to bound addresses. | Class | akka.remote | Akka |
|
| BoundedBlockingQueue | BoundedBlockingQueue wraps any Queue and turns the result into a BlockingQueue with a limited capacity. | Class | akka.util | Akka |
|
| BoundedControlAwareMailbox | BoundedControlAwareMailbox is a bounded MailboxType, that maintains two queues to allow messages that extend ControlMessage to be delivered with priority. | Class | akka.dispatch | Akka |
|
| BoundedControlAwareMailbox$ | | Class | akka.dispatch | Akka |
|
| BoundedControlAwareMessageQueueSemantics | | Interface | akka.dispatch | Akka |
|
| BoundedDequeBasedMailbox | BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque. | Class | akka.dispatch | Akka |
|
| BoundedDequeBasedMailbox$ | | Class | akka.dispatch | Akka |
|
| BoundedDequeBasedMessageQueue | BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i. | Interface | akka.dispatch | Akka |
|
| BoundedDequeBasedMessageQueueSemantics | | Interface | akka.dispatch | Akka |
|
| BoundedMailbox | BoundedMailbox is the default bounded MailboxType used by Akka Actors. | Class | akka.dispatch | Akka |
|
| BoundedMailbox$ | | Class | akka.dispatch | Akka |
|
| BoundedMessageQueueSemantics | BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i. | Interface | akka.dispatch | Akka |
|
| BoundedNodeMessageQueue | Lock-free bounded non-blocking multiple-producer single-consumer queue. | Class | akka.dispatch | Akka |
|
| BoundedPriorityMailbox | BoundedPriorityMailbox is a bounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
| BoundedPriorityMailbox$ | | Class | akka.dispatch | Akka |
|
| BoundedQueueBasedMessageQueue | Try to dequeue the next message from this queue, return null failing that. | Interface | akka.dispatch | Akka |
|
| BoundedStablePriorityMailbox | BoundedStablePriorityMailbox is a bounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
| BoundedStablePriorityMailbox$ | | Class | akka.dispatch | Akka |
|
| BoxedType | | Class | akka.util | Akka |
|
| BoxedType$ | | Class | akka.util | Akka |
|
| Broadcast | Used to broadcast a message to all routees in a router; only the contained message will be forwarded, i. | Class | akka.routing | Akka |
|
| Broadcast$ | | Class | akka.routing | Akka |
|
| BroadcastGroup | A router group that broadcasts a message to all its routees. | Class | akka.routing | Akka |
|
| BroadcastGroup$ | | Class | akka.routing | Akka |
|
| BroadcastPool | A router pool that broadcasts a message to all its routees. | Class | akka.routing | Akka |
|
| BroadcastPool$ | | Class | akka.routing | Akka |
|
| BroadcastRoutingLogic | Broadcasts a message to all its routees. | Class | akka.routing | Akka |
|
| BroadcastRoutingLogic$ | | Class | akka.routing | Akka |
|
| BufferPool | java. | Interface | akka.io | Akka |
|
| BundleDelegatingClassLoader | | Class | akka.osgi | Akka |
|
| BundleDelegatingClassLoader$ | | Class | akka.osgi | Akka |
|
| BusLogging | LoggingAdapter that publishes Logging. | Class | akka.event | Akka |
|
| ByteArraySerializer | This is a special Serializer that Serializes and deserializes byte arrays only, (just returns the byte array unchanged/uncopied) | Class | akka.serialization | Akka |
|
| ByteIterator | An iterator over a ByteString. | Class | akka.util | Akka |
|
| ByteIterator$ | | Class | akka.util | Akka |
|
| ByteString | Immutable sequence of bytes. | Class | akka.protobuf | Akka |
|
| ByteString | A rope-like immutable data structure containing bytes. | Class | akka.util | Akka |
|
| ByteString$ | | Class | akka.util | Akka |
|
| ByteStringBuilder | A mutable builder for efficiently creating a ByteString. | Class | akka.util | Akka |
|
| CachingConfig | A CachingConfig is a Config that wraps another Config and is used to cache path lookup and string retrieval, which we happen to do a lot in some critical paths of the actor creation and mailbox | Class | akka.dispatch | Akka |
|
| CachingConfig$ | | Class | akka.dispatch | Akka |
|
| CachingPartialFunction | This is a specialized variant of PartialFunction which is only applicable if you know that isDefinedAt(x) is always called before | Class | akka.testkit | Akka |
|
| CallingThreadDispatcher | Dispatcher which runs invocations on the current thread only. | Class | akka.testkit | Akka |
|
| CallingThreadDispatcher$ | | Class | akka.testkit | Akka |
|
| CallingThreadDispatcherConfigurator | | Class | akka.testkit | Akka |
|
| CallingThreadDispatcherQueues | | Class | akka.testkit | Akka |
|
| CallingThreadDispatcherQueues$ | | Class | akka.testkit | Akka |
|
| CallingThreadMailbox | | Class | akka.testkit | Akka |
|
| Camel | Camel trait encapsulates the underlying camel machinery. | Interface | akka.camel | Akka |
|
| CamelExchangeAdapter | Adapter for converting an Exchange to and from CamelMessage and FailureResult objects. | Class | akka.camel.internal | Akka |
|
| CamelExtension | This class can be used to get hold of an instance of the Camel class bound to the actor system. | Class | akka.camel | Akka |
|
| CamelExtension$ | This class can be used to get hold of an instance of the Camel class bound to the actor system. | Class | akka.camel | Akka |
|
| CamelMessage | An immutable representation of a Camel message. | Class | akka.camel | Akka |
|
| CamelMessage$ | Companion object of CamelMessage class. | Class | akka.camel | Akka |
|
| CamelPath | Converts ActorRefs and actorPaths to URI's that point to the actor through the Camel Actor Component. | Class | akka.camel.internal.component | Akka |
|
| CamelPath$ | Converts ActorRefs and actorPaths to URI's that point to the actor through the Camel Actor Component. | Class | akka.camel.internal.component | Akka |
|
| CamelSettings | Settings for the Camel Extension param: config the config | Class | akka.camel | Akka |
|
| CamelSupervisor | | Class | akka.camel.internal | Akka |
|
| CamelSupervisor$ | Messages for the camel supervisor, registrations and de-registrations. | Class | akka.camel.internal | Akka |
|
| CamelSupport | Returns a Camel trait which provides access to the CamelExtension. | Interface | akka.camel | Akka |
|
| Cancellable | Signifies something that can be cancelled There is no strict guarantee that the implementation is thread-safe, | Interface | akka.actor | Akka |
|
| CapabilityFlag | | Class | akka.persistence | Akka |
|
| CapabilityFlag$ | | Class | akka.persistence | Akka |
|
| CapacityMetricsSelector | A MetricsSelector producing weights from remaining capacity. | Class | akka.cluster.metrics | Akka |
|
| CapacityMetricsSelector | A MetricsSelector producing weights from remaining capacity. | Class | akka.cluster.routing | Akka |
|
| CaseStatement | | Class | akka.japi.pf | Akka |
|
| CaseStatement$ | | Class | akka.japi.pf | Akka |
|
| Cell | All children of this actor, including only reserved-names. | Interface | akka.actor | Akka |
|
| ChannelLocalActor | | Class | akka.remote.transport.netty | Akka |
|
| ChannelLocalActor$ | | Class | akka.remote.transport.netty | Akka |
|
| ChannelRegistration | a result of it having called register on the ChannelRegistry. | Interface | akka.io | Akka |
|
| ChannelRegistry | | Interface | akka.io | Akka |
|
| ChildActorPath | | Class | akka.actor | Akka |
|
| ChildNameReserved | | Class | akka.actor | Akka |
|
| ChildNameReserved$ | | Class | akka.actor | Akka |
|
| Children | java. | Interface | akka.actor.dungeon | Akka |
|
| ChildrenContainer | | Interface | akka.actor.dungeon | Akka |
|
| ChildrenContainer$ | This object holds the classes performing the logic of managing the children of an actor, hence they are intimately tied to ActorCell. | Class | akka.actor.dungeon | Akka |
|
| ChildRestartStats | ChildRestartStats is the statistics kept by every parent Actor for every child Actor and is used for SupervisorStrategies to know how to deal with problems that occur for the children. | Class | akka.actor | Akka |
|
| ChildRestartStats$ | | Class | akka.actor | Akka |
|
| CircuitBreaker | Provides circuit breaker functionality to provide stability when working with "dangerous" operations, e. | Class | akka.pattern | Akka |
|
| CircuitBreaker$ | | Class | akka.pattern | Akka |
|
| CircuitBreakerOpenException | Exception thrown when Circuit Breaker is open. | Class | akka.pattern | Akka |
|
| CircuitBreakerOpenException$ | | Class | akka.pattern | Akka |
|
| ClassLoaderObjectInputStream | ClassLoaderObjectInputStream tries to utilize the provided ClassLoader to load Classes and falls back to ObjectInputStreams resolver. | Class | akka.util | Akka |
|
| Client | | Class | akka.remote.testconductor | Akka |
|
| Client$ | | Class | akka.remote.testconductor | Akka |
|
| ClientFSM | This is the controlling entity on the Player side: in a first step it registers itself with a symbolic name and its remote | Class | akka.remote.testconductor | Akka |
|
| ClientFSM$ | | Class | akka.remote.testconductor | Akka |
|
| ClientHandler | | Class | akka.remote.transport.netty | Akka |
|
| Cluster | This module is responsible cluster membership information. | Class | akka.cluster | Akka |
|
| Cluster$ | Cluster Extension Id and factory for creating Cluster extension. | Class | akka.cluster | Akka |
|
| ClusterActorRefProvider | The ClusterActorRefProvider will load the Cluster extension, i. | Class | akka.cluster | Akka |
|
| ClusterClient | This actor is intended to be used on an external node that is not member of the cluster. | Class | akka.cluster.client | Akka |
|
| ClusterClient$ | | Class | akka.cluster.client | Akka |
|
| ClusterClientMessages | | Class | akka.cluster.client.protobuf.msg | Akka |
|
| ClusterClientMessageSerializer | INTERNAL API: Serializer of ClusterClient messages. | Class | akka.cluster.client.protobuf | Akka |
|
| ClusterClientReceptionist | Extension that starts ClusterReceptionist and accompanying DistributedPubSubMediator with settings defined in config section akka. | Class | akka.cluster.client | Akka |
|
| ClusterClientReceptionist$ | | Class | akka.cluster.client | Akka |
|
| ClusterClientSettings | param: initialContacts Actor paths of the ClusterReceptionist actors on the servers (cluster nodes) that the client will try to contact initially. | Class | akka.cluster.client | Akka |
|
| ClusterClientSettings$ | | Class | akka.cluster.client | Akka |
|
| ClusterCoreDaemon | | Class | akka.cluster | Akka |
|
| ClusterCoreSupervisor | ClusterCoreDaemon and ClusterDomainEventPublisher can't be restarted because the state would be obsolete. | Class | akka.cluster | Akka |
|
| ClusterDaemon | Supervisor managing the different Cluster daemons. | Class | akka.cluster | Akka |
|
| ClusterDeployer | Deployer of cluster aware routers. | Class | akka.cluster | Akka |
|
| ClusterDomainEventPublisher | Responsible for domain event subscriptions and publishing of domain events to event bus. | Class | akka.cluster | Akka |
|
| ClusterEvent | Domain events published to the event bus. | Class | akka.cluster | Akka |
|
| ClusterEvent$ | Domain events published to the event bus. | Class | akka.cluster | Akka |
|
| ClusterHeartbeatReceiver | Receives Heartbeat messages and replies. | Class | akka.cluster | Akka |
|
| ClusterHeartbeatSender | | Class | akka.cluster | Akka |
|
| ClusterHeartbeatSender$ | | Class | akka.cluster | Akka |
|
| ClusterHeartbeatSenderState | State of ClusterHeartbeatSender. | Class | akka.cluster | Akka |
|
| ClusterHeartbeatSenderState$ | | Class | akka.cluster | Akka |
|
| ClusterJmx | | Class | akka.cluster | Akka |
|
| ClusterMessages | | Class | akka.cluster.protobuf.msg | Akka |
|
| ClusterMessageSerializer | Protobuf serializer of cluster messages. | Class | akka.cluster.protobuf | Akka |
|
| ClusterMetricsChanged | Current snapshot of cluster node metrics. | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsChanged$ | | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsCollector | Cluster metrics is primarily for load-balancing of nodes. | Class | akka.cluster | Akka |
|
| ClusterMetricsCollector | Actor responsible for periodic data sampling in the node and publication to the cluster. | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsExtension | Cluster metrics extension. | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsExtension$ | Cluster metrics extension provider. | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsMessages | | Class | akka.cluster.metrics.protobuf.msg | Akka |
|
| ClusterMetricsSettings | Metrics extension settings. | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsSettings$ | | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsStrategy | Default ClusterMetricsSupervisor strategy: A configurable OneForOneStrategy with restart-on-throwable decider. | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsStrategy$ | Provide custom metrics strategy resources. | Class | akka.cluster.metrics | Akka |
|
| ClusterMetricsSupervisor | Actor providing customizable metrics collection supervision. | Class | akka.cluster.metrics | Akka |
|
| ClusterNodeMBean | Interface for the cluster JMX MBean. | Interface | akka.cluster | Akka |
|
| ClusterReadView | Read view of cluster state, updated via subscription of cluster events published on the event bus. | Class | akka.cluster | Akka |
|
| ClusterReceptionist | ClusterClient connects to this actor to retrieve. | Class | akka.cluster.client | Akka |
|
| ClusterReceptionist$ | | Class | akka.cluster.client | Akka |
|
| ClusterReceptionistSettings | param: role Start the receptionist on members tagged with this role. | Class | akka.cluster.client | Akka |
|
| ClusterReceptionistSettings$ | | Class | akka.cluster.client | Akka |
|
| ClusterRemoteWatcher | Specialization of RemoteWatcher that keeps track of cluster member nodes and is responsible for watchees on cluster nodes. | Class | akka.cluster | Akka |
|
| ClusterRemoteWatcher$ | | Class | akka.cluster | Akka |
|
| ClusterRouterActor | The router actor, subscribes to cluster events and adjusts the routees. | Interface | akka.cluster.routing | Akka |
|
| ClusterRouterConfigBase | Create the actual router, responsible for routing messages to routees. | Interface | akka.cluster.routing | Akka |
|
| ClusterRouterGroup | RouterConfig implementation for deployment on cluster nodes. | Class | akka.cluster.routing | Akka |
|
| ClusterRouterGroup$ | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterGroupActor | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterGroupSettings | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterGroupSettings$ | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterPool | RouterConfig implementation for deployment on cluster nodes. | Class | akka.cluster.routing | Akka |
|
| ClusterRouterPool$ | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterPoolActor | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterPoolSettings | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterPoolSettings$ | | Class | akka.cluster.routing | Akka |
|
| ClusterRouterSettingsBase | | Interface | akka.cluster.routing | Akka |
|
| ClusterRouterSettingsBase$ | | Class | akka.cluster.routing | Akka |
|
| ClusterScope | | Class | akka.cluster | Akka |
|
| ClusterScope$ | Cluster aware scope of a DeploySee Also:Serialized Form | Class | akka.cluster | Akka |
|
| ClusterSettings | | Class | akka.cluster | Akka |
|
| ClusterSharding | | Class | akka.cluster.sharding | Akka |
|
| ClusterSharding$ | This extension provides sharding functionality of actors in a cluster. | Class | akka.cluster.sharding | Akka |
|
| ClusterShardingGuardian | INTERNAL API. | Class | akka.cluster.sharding | Akka |
|
| ClusterShardingGuardian$ | | Class | akka.cluster.sharding | Akka |
|
| ClusterShardingMessages | | Class | akka.cluster.sharding.protobuf.msg | Akka |
|
| ClusterShardingMessageSerializer | INTERNAL API: Protobuf serializer of ClusterSharding messages. | Class | akka.cluster.sharding.protobuf | Akka |
|
| ClusterShardingSettings | param: role specifies that this entity type requires cluster nodes with a specific role. | Class | akka.cluster.sharding | Akka |
|
| ClusterShardingSettings$ | | Class | akka.cluster.sharding | Akka |
|
| ClusterSingletonManager | Manages singleton actor instance among all cluster nodes or a group of nodes tagged with a specific role. | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonManager$ | | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonManagerIsStuck | Thrown when a consistent state can't be determined within the defined retry limits. | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonManagerSettings | param: singletonName The actor name of the child singleton actor. | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonManagerSettings$ | | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonMessageSerializer | INTERNAL API: Serializer of ClusterSingleton messages. | Class | akka.cluster.singleton.protobuf | Akka |
|
| ClusterSingletonProxy | The ClusterSingletonProxy works together with the ClusterSingletonManager to provide a distributed proxy to the singleton actor. | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonProxy$ | | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonProxySettings | param: singletonName The actor name of the singleton actor that is started by the ClusterSingletonManager. | Class | akka.cluster.singleton | Akka |
|
| ClusterSingletonProxySettings$ | | Class | akka.cluster.singleton | Akka |
|
| ClusterUserAction | | Class | akka.cluster | Akka |
|
| ClusterUserAction$ | | Class | akka.cluster | Akka |
|
| CodedInputStream | Reads and decodes protocol message fields. | Class | akka.protobuf | Akka |
|
| CodedOutputStream | Encodes and writes protocol message fields. | Class | akka.protobuf | Akka |
|
| CollectionControlMessage | Runtime collection management commands. | Class | akka.cluster.metrics | Akka |
|
| Collections | | Class | akka.util | Akka |
|
| Collections$ | | Class | akka.util | Akka |
|
| CollectionStartMessage | Command for ClusterMetricsSupervisor to start metrics collection. | Class | akka.cluster.metrics | Akka |
|
| CollectionStartMessage$ | Command for ClusterMetricsSupervisor to start metrics collection. | Class | akka.cluster.metrics | Akka |
|
| CollectionStopMessage | Command for ClusterMetricsSupervisor to stop metrics collection. | Class | akka.cluster.metrics | Akka |
|
| CollectionStopMessage$ | Command for ClusterMetricsSupervisor to stop metrics collection. | Class | akka.cluster.metrics | Akka |
|
| CommonHandlers | | Interface | akka.remote.transport.netty | Akka |
|
| CompactByteString | A compact ByteString. | Class | akka.util | Akka |
|
| CompactByteString$ | | Class | akka.util | Akka |
|
| ConcurrentMultiMap | An implementation of a ConcurrentMultiMap Adds/remove is serialized over the specified key | Class | akka.util | Akka |
|
| Conductor | The conductor is the one orchestrating the test: it governs the Controller’s port to which all | Interface | akka.remote.testconductor | Akka |
|
| ConductorHandler | This handler is installed at the end of the controller’s netty pipeline. | Class | akka.remote.testconductor | Akka |
|
| ConfigurationException | This exception is thrown when Akka detects a problem with the provided configurationSee Also:Serialized Form | Class | akka | Akka |
|
| ConsistentHash | Consistent Hashing node ring implementation. | Class | akka.routing | Akka |
|
| ConsistentHash$ | | Class | akka.routing | Akka |
|
| ConsistentHashingGroup | A router group that uses consistent hashing to select a routee based on the sent message. | Class | akka.routing | Akka |
|
| ConsistentHashingGroup$ | | Class | akka.routing | Akka |
|
| ConsistentHashingPool | A router pool that uses consistent hashing to select a routee based on the sent message. | Class | akka.routing | Akka |
|
| ConsistentHashingPool$ | | Class | akka.routing | Akka |
|
| ConsistentHashingRouter | | Class | akka.routing | Akka |
|
| ConsistentHashingRouter$ | | Class | akka.routing | Akka |
|
| ConsistentHashingRoutingLogic | | Class | akka.routing | Akka |
|
| ConsistentHashingRoutingLogic$ | | Class | akka.routing | Akka |
|
| ConsistentRoutee | Important to use ActorRef with full address, with host and port, in the hash ring, so that same ring is produced on different nodes. | Class | akka.routing | Akka |
|
| ConsistentRoutee$ | | Class | akka.routing | Akka |
|
| Consumer | Mixed in by Actor implementations that consume message from Camel endpoints. | Interface | akka.camel | Akka |
|
| Consumer$ | | Class | akka.camel | Akka |
|
| ConsumerActorRouteBuilder | Builder of a route to a target which can be an actor. | Class | akka.camel.internal | Akka |
|
| ConsumerConfig | Captures the configuration of the Consumer. | Class | akka.camel | Akka |
|
| ConsumerConfig$ | | Class | akka.camel | Akka |
|
| ConsumerRegistrar | Registers Consumers. | Class | akka.camel.internal | Akka |
|
| ContainerFormats | | Class | akka.remote | Akka |
|
| ContextProvider | An instance of this class must be instantiable using a no-arg constructor. | Interface | akka.camel | Akka |
|
| ContextualTypedActorFactory | ContextualTypedActorFactory allows TypedActors to create children, effectively forming the same Actor Supervision Hierarchies as normal Actors can. | Class | akka.actor | Akka |
|
| ContextualTypedActorFactory$ | | Class | akka.actor | Akka |
|
| ControlAwareMessageQueueSemantics | ControlAwareMessageQueue handles messages that extend ControlMessage with priority. | Interface | akka.dispatch | Akka |
|
| Controller | This controls test execution by managing barriers (delegated to BarrierCoordinator, its child) and allowing | Class | akka.remote.testconductor | Akka |
|
| Controller$ | | Class | akka.remote.testconductor | Akka |
|
| CpuMetricsSelector | MetricsSelector that uses the combined CPU time metrics and stolen CPU time metrics. | Class | akka.cluster.metrics | Akka |
|
| CpuMetricsSelector | MetricsSelector that uses the combined CPU metrics. | Class | akka.cluster.routing | Akka |
|
| CpuMetricsSelector$ | MetricsSelector that uses the combined CPU time metrics and stolen CPU time metrics. | Class | akka.cluster.metrics | Akka |
|
| CpuMetricsSelector$ | MetricsSelector that uses the combined CPU metrics. | Class | akka.cluster.routing | Akka |
|
| Create | | Class | akka.dispatch.sysmsg | Akka |
|
| Create$ | | Class | akka.dispatch.sysmsg | Akka |
|
| Creator | A constructor/factory, takes no parameters but creates a new value of type T every call. | Interface | akka.japi | Akka |
|
| Creator | A constructor/factory, takes no parameters but creates a new value of type T every call. | Interface | akka.japi.function | Akka |
|
| CreatorConsumer | | Class | akka.actor | Akka |
|
| CreatorFunctionConsumer | | Class | akka.actor | Akka |
|
| Creators | | Interface | akka.actor.dsl | Akka |
|
| Crypt | | Class | akka.util | Akka |
|
| Crypt$ | | Class | akka.util | Akka |
|
| CurrentEventsByPersistenceIdPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| CurrentEventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
|
| CurrentEventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
|
| CurrentEventsByTagPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| CurrentEventsByTagQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
|
| CurrentEventsByTagQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
|
| CurrentPersistenceIdsQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
|
| CurrentPersistenceIdsQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
|
| CustomEventFilter | Custom event filter when the others do not fit the bill. | Class | akka.testkit | Akka |
|
| CustomEventFilter$ | | Class | akka.testkit | Akka |
|
| CustomRouterConfig | If a custom router implementation is not a Group nor a Pool it may extend this base class. | Class | akka.routing | Akka |
|
| DaemonMsgCreate | | Class | akka.remote | Akka |
|
| DaemonMsgCreate$ | | Class | akka.remote | Akka |
|
| DaemonMsgCreateSerializer | Serializes Akka's internal DaemonMsgCreate using protobuf for the core structure of DaemonMsgCreate, Props and Deploy. | Class | akka.remote.serialization | Akka |
|
| DDataShardCoordinator | Singleton coordinator (with state based on ddata) that decides where to allocate shards. | Class | akka.cluster.sharding | Akka |
|
| DeadLetter | When a message is sent to an Actor that is terminated before receiving the message, it will be sent as a DeadLetter to the ActorSystem's EventStream | Class | akka.actor | Akka |
|
| DeadLetter$ | | Class | akka.actor | Akka |
|
| DeadLetterActorRef | Internal implementation of the dead letter destination: will publish any received message to the eventStream, wrapped as DeadLetter. | Class | akka.actor | Akka |
|
| DeadLetterActorRef$ | | Class | akka.actor | Akka |
|
| DeadLetterListener | | Class | akka.event | Akka |
|
| DeadLettersFilter | | Class | akka.testkit | Akka |
|
| DeadLettersFilter$ | | Class | akka.testkit | Akka |
|
| DeadlineFailureDetector | to trigger unavailability. | Class | akka.remote | Akka |
|
| Deafen | | Class | akka.routing | Akka |
|
| Deafen$ | | Class | akka.routing | Akka |
|
| DeathPactException | A DeathPactException is thrown by an Actor that receives a Terminated(someActor) message that it doesn't handle itself, effectively crashing the Actor and escalating to the supervisor. | Class | akka.actor | Akka |
|
| DeathPactException$ | | Class | akka.actor | Akka |
|
| DeathWatch | | Interface | akka.actor.dungeon | Akka |
|
| DeathWatchNotification | | Class | akka.dispatch.sysmsg | Akka |
|
| DeathWatchNotification$ | | Class | akka.dispatch.sysmsg | Akka |
|
| DebugFilter | Filter which matches Debug events, if they satisfy the given criteria: source, if given, applies a filter on the event’s originmessage applies a filter on the event’s message (either with String. | Class | akka.testkit | Akka |
|
| DebugFilter$ | | Class | akka.testkit | Akka |
|
| DeciderBuilder | Used for building a partial function for Actor. | Class | akka.japi.pf | Akka |
|
| DefaultCamel | Creates an instance of the Camel subsystem. | Class | akka.camel.internal | Akka |
|
| DefaultContextProvider | Default implementation of ContextProvider Provides a new DefaultCamelContext per actor system | Class | akka.camel | Akka |
|
| DefaultDispatcherPrerequisites | | Class | akka.dispatch | Akka |
|
| DefaultDispatcherPrerequisites$ | | Class | akka.dispatch | Akka |
|
| DefaultExecutorServiceConfigurator | | Class | akka.dispatch | Akka |
|
| DefaultFailureDetectorRegistry | A lock-less thread-safe implementation of FailureDetectorRegistry. | Class | akka.remote | Akka |
|
| DefaultLoggingFilter | Default LoggingFilter that uses the logLevel of the eventStream, which initial value is defined in configuration. | Class | akka.event | Akka |
|
| DefaultMessageDispatcher | | Class | akka.remote | Akka |
|
| DefaultOptimalSizeExploringResizer | This resizer resizes the pool to an optimal size that provides the most message throughput. | Class | akka.routing | Akka |
|
| DefaultOptimalSizeExploringResizer$ | | Class | akka.routing | Akka |
|
| DefaultOSGiLogger | Logger for OSGi environment. | Class | akka.osgi | Akka |
|
| DefaultResizer | | Class | akka.routing | Akka |
|
| DefaultResizer$ | | Class | akka.routing | Akka |
|
| DefaultSigarProvider | Provide sigar instance as SigarProxy with configured location via ClusterMetricsSettings. | Class | akka.cluster.metrics | Akka |
|
| DefaultSigarProvider$ | | Class | akka.cluster.metrics | Akka |
|
| DefaultSupervisorStrategy | | Class | akka.actor | Akka |
|
| DefaultSystemMessageQueue | | Interface | akka.dispatch | Akka |
|
| DeleteMessagesFailure | Reply message to a failed Eventsourced. | Class | akka.persistence | Akka |
|
| DeleteMessagesFailure$ | | Class | akka.persistence | Akka |
|
| DeleteMessagesSuccess | Reply message to a successful Eventsourced. | Class | akka.persistence | Akka |
|
| DeleteMessagesSuccess$ | | Class | akka.persistence | Akka |
|
| DeleteSnapshotFailure | Sent to a PersistentActor after failed deletion of a snapshot. | Class | akka.persistence | Akka |
|
| DeleteSnapshotFailure$ | | Class | akka.persistence | Akka |
|
| DeleteSnapshotsFailure | Sent to a PersistentActor after failed deletion of a range of snapshots. | Class | akka.persistence | Akka |
|
| DeleteSnapshotsFailure$ | | Class | akka.persistence | Akka |
|
| DeleteSnapshotsSuccess | Sent to a PersistentActor after successful deletion of specified range of snapshots. | Class | akka.persistence | Akka |
|
| DeleteSnapshotsSuccess$ | | Class | akka.persistence | Akka |
|
| DeleteSnapshotSuccess | Sent to a PersistentActor after successful deletion of a snapshot. | Class | akka.persistence | Akka |
|
| DeleteSnapshotSuccess$ | | Class | akka.persistence | Akka |
|
| DeliveryBuffer | scala. | Interface | akka.persistence.query.journal.leveldb | Akka |
|
| Deploy | | Class | akka.actor | Akka |
|
| Deploy$ | | Class | akka.actor | Akka |
|
| Deployer | Deployer maps actor paths to actor deployments. | Class | akka.actor | Akka |
|
| DequeBasedMessageQueue | | Interface | akka.dispatch | Akka |
|
| DequeBasedMessageQueueSemantics | DequeBasedMessageQueue refines QueueBasedMessageQueue to be backed by a java. | Interface | akka.dispatch | Akka |
|
| DescriptorProtos | | Class | akka.protobuf | Akka |
|
| Descriptors | Contains a collection of classes which describe protocol message types. | Class | akka.protobuf | Akka |
|
| DiagnosticActorLogging | Scala API: Mix in DiagnosticActorLogging into your Actor to easily obtain a reference to a logger with MDC support, which is available under the name "log". | Interface | akka.actor | Akka |
|
| DiagnosticLoggingAdapter | LoggingAdapter extension which adds MDC support. | Interface | akka.event | Akka |
|
| DirectByteBufferPool | A buffer pool which keeps a free list of direct buffers of a specified default size in a simple fixed size stack. | Class | akka.io | Akka |
|
| DisassociatedEvent | | Class | akka.remote | Akka |
|
| DisassociatedEvent$ | | Class | akka.remote | Akka |
|
| Disconnect | | Class | akka.remote.testconductor | Akka |
|
| Disconnect$ | | Class | akka.remote.testconductor | Akka |
|
| DisconnectMsg | | Class | akka.remote.testconductor | Akka |
|
| DisconnectMsg$ | | Class | akka.remote.testconductor | Akka |
|
| Dispatch | | Interface | akka.actor.dungeon | Akka |
|
| Dispatcher | The event-based Dispatcher binds a set of Actors to a thread pool backed up by a The preferred way of creating dispatchers is to define configuration of it and use the | Class | akka.dispatch | Akka |
|
| DispatcherConfigurator | Configurator for creating Dispatcher. | Class | akka.dispatch | Akka |
|
| DispatcherPrerequisites | DispatcherPrerequisites represents useful contextual pieces when constructing a MessageDispatcher | Interface | akka.dispatch | Akka |
|
| Dispatchers | Dispatchers are to be defined in configuration to allow for tuning for different environments. | Class | akka.dispatch | Akka |
|
| Dispatchers$ | | Class | akka.dispatch | Akka |
|
| DistributedData | Akka extension for convenient configuration and use of the Replicator. | Class | akka.cluster.ddata | Akka |
|
| DistributedData$ | | Class | akka.cluster.ddata | Akka |
|
| DistributedPubSub | Extension that starts a DistributedPubSubMediator actor with settings defined in config section akka. | Class | akka.cluster.pubsub | Akka |
|
| DistributedPubSub$ | | Class | akka.cluster.pubsub | Akka |
|
| 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 | Class | akka.cluster.pubsub | Akka |
|
| DistributedPubSubMediator$ | | Class | akka.cluster.pubsub | Akka |
|
| DistributedPubSubMessages | | Class | akka.cluster.pubsub.protobuf.msg | Akka |
|
| DistributedPubSubMessageSerializer | INTERNAL API: Protobuf serializer of DistributedPubSubMediator messages. | Class | akka.cluster.pubsub.protobuf | Akka |
|
| DistributedPubSubSettings | param: role Start the mediator on members tagged with this role. | Class | akka.cluster.pubsub | Akka |
|
| DistributedPubSubSettings$ | | Class | akka.cluster.pubsub | Akka |
|
| Dns | | Class | akka.io | Akka |
|
| Dns$ | | Class | akka.io | Akka |
|
| DnsExt | | Class | akka.io | Akka |
|
| DnsProvider | java. | Interface | akka.io | Akka |
|
| Done | | Class | akka.remote.testconductor | Akka |
|
| Done$ | | Class | akka.remote.testconductor | Akka |
|
| DummyClassForStringSources | This is a “marker” class which is inserted as originator class into Logging. | Class | akka.event | Akka |
|
| DurationTypeConverter | | Class | akka.camel.internal.component | Akka |
|
| DurationTypeConverter$ | | Class | akka.camel.internal.component | Akka |
|
| DynamicAccess | The DynamicAccess implementation is the class which is used for loading all configurable parts of an actor system (the | Class | akka.actor | Akka |
|
| DynamicMessage | An implementation of Message that can represent arbitrary types, given a Descriptors. | Class | akka.protobuf | Akka |
|
| EarliestFirstSystemMessageList | Value class supporting list operations on system messages. | Class | akka.dispatch.sysmsg | Akka |
|
| EarliestFirstSystemMessageList$ | | Class | akka.dispatch.sysmsg | Akka |
|
| Effect | An executable piece of code that takes no parameters and doesn't return any value. | Interface | akka.japi.function | Akka |
|
| Effect | All tracked effects must extend implement this type. | Class | akka.typed | Akka |
|
| Effect$ | | Class | akka.typed | Akka |
|
| EffectfulActorContext | An ActorContext for testing purposes that records the effects performed on it and otherwise stubs them out like a StubbedActorContext. | Class | akka.typed | Akka |
|
| EmptyEventSeq$ | | Class | akka.persistence.journal | Akka |
|
| EmptyLocalActorRef | This special dead letter reference has a name: it is that which is returned by a local look-up which is unsuccessful. | Class | akka.actor | Akka |
|
| EndpointActor | | Class | akka.remote | Akka |
|
| EndpointAssociationException | | Class | akka.remote | Akka |
|
| EndpointDisassociatedException | | Class | akka.remote | Akka |
|
| EndpointException | | Class | akka.remote | Akka |
|
| EndpointManager | | Class | akka.remote | Akka |
|
| EndpointManager$ | | Class | akka.remote | Akka |
|
| EndpointReader | | Class | akka.remote | Akka |
|
| EndpointReader$ | | Class | akka.remote | Akka |
|
| EndpointWriter | | Class | akka.remote | Akka |
|
| EndpointWriter$ | | Class | akka.remote | Akka |
|
| EnterBarrier | | Class | akka.remote.testconductor | Akka |
|
| EnterBarrier$ | | Class | akka.remote.testconductor | Akka |
|
| Envelope | | Class | akka.dispatch | Akka |
|
| Envelope$ | | Class | akka.dispatch | Akka |
|
| ErrorFilter | Filter which matches Error events, if they satisfy the given criteria: throwable applies an upper bound on the type of exception contained in the Error eventsource, if given, applies a filter on the event’s originmessage applies a filter on the event’s message (either | Class | akka.testkit | Akka |
|
| ErrorFilter$ | | Class | akka.testkit | Akka |
|
| EventAdapter | An EventAdapter is both a WriteEventAdapter and a ReadEventAdapter. | Interface | akka.persistence.journal | Akka |
|
| EventAdapters | EventAdapters serves as a per-journal collection of bound event adapters. | Class | akka.persistence.journal | Akka |
|
| EventAdapters$ | | Class | akka.persistence.journal | Akka |
|
| EventBus | Represents the base type for EventBuses Internally has an Event type, a Classifier type and a Subscriber type | Interface | akka.event | Akka |
|
| EventBus | Java API: See documentation for EventBus E is the Event type | Interface | akka.event.japi | Akka |
|
| EventEnvelope | Event wrapper adding meta data for the events in the result stream of EventsByTagQuery query, or similar queries. | Class | akka.persistence.query | Akka |
|
| EventEnvelope$ | | Class | akka.persistence.query | Akka |
|
| EventFilter | Facilities for selectively filtering out expected events from logging so that you can keep your test run’s console output clean and do not miss real | Class | akka.testkit | Akka |
|
| EventFilter$ | Facilities for selectively filtering out expected events from logging so that you can keep your test run’s console output clean and do not miss real | Class | akka.testkit | Akka |
|
| EventPublisher | | Class | akka.remote | Akka |
|
| EventsByPersistenceIdPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| EventsByPersistenceIdPublisher$ | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| EventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
|
| EventsByPersistenceIdQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
|
| EventsByTagPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| EventsByTagPublisher$ | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| EventsByTagQuery | A plugin may optionally support this query by implementing this interface. | Interface | akka.persistence.query.javadsl | Akka |
|
| EventsByTagQuery | A plugin may optionally support this query by implementing this trait. | Interface | akka.persistence.query.scaladsl | Akka |
|
| EventSeq | | Class | akka.persistence.journal | Akka |
|
| EventSeq$ | | Class | akka.persistence.journal | Akka |
|
| Eventsourced | Scala API and implementation details of PersistentActor, AbstractPersistentActor and UntypedPersistentActor. | Interface | akka.persistence | Akka |
|
| Eventsourced$ | | Class | akka.persistence | Akka |
|
| EventsSeq | | Class | akka.persistence.journal | Akka |
|
| EventsSeq$ | | Class | akka.persistence.journal | Akka |
|
| EventStream | | Class | akka.event | Akka |
|
| EventStream$ | | Class | akka.event | Akka |
|
| EventStreamUnsubscriber | Watches all actors which subscribe on the given eventStream, and unsubscribes them from it when they are Terminated. | Class | akka.event | Akka |
|
| EventStreamUnsubscriber$ | Provides factory for EventStreamUnsubscriber actors with **unique names**. | Class | akka.event | Akka |
|
| EWMA | | Class | akka.cluster | Akka |
|
| EWMA | The exponentially weighted moving average (EWMA) approach captures short-term movements in volatility for a conditional volatility forecasting model. | Class | akka.cluster.metrics | Akka |
|
| EWMA$ | | Class | akka.cluster | Akka |
|
| EWMA$ | | Class | akka.cluster.metrics | Akka |
|
| ExecutionContexts | | Class | akka.dispatch | Akka |
|
| ExecutionContexts$ | | Class | akka.dispatch | Akka |
|
| ExecutorServiceConfigurator | | Class | akka.dispatch | Akka |
|
| ExecutorServiceDelegate | java. | Interface | akka.dispatch | Akka |
|
| ExecutorServiceFactory | createExecutorServicejava. | Interface | akka.dispatch | Akka |
|
| ExecutorServiceFactoryProvider | java. | Interface | akka.dispatch | Akka |
|
| ExplicitAskSupport | This object contains implementation details of the “ask” pattern, which can be combined with "replyTo" pattern. | Interface | akka.pattern | Akka |
|
| ExplicitlyAskableActorRef | | Class | akka.pattern | Akka |
|
| ExplicitlyAskableActorRef$ | | Class | akka.pattern | Akka |
|
| ExplicitlyAskableActorSelection | | Class | akka.pattern | Akka |
|
| ExplicitlyAskableActorSelection$ | | Class | akka.pattern | Akka |
|
| ExtendedActorSystem | More powerful interface to the actor system’s implementation which is presented to extensions (see Extension). | Class | akka.actor | Akka |
|
| Extension | The basic ActorSystem covers all that is needed for locally running actors, using futures and so on. | Interface | akka.actor | Akka |
|
| ExtensionId | Identifies an Extension Lookup of Extensions is done by object identity, so the Id must be the same wherever it's used, | Interface | akka.actor | Akka |
|
| ExtensionIdProvider | To be able to load an ExtensionId from the configuration, a class that implements ExtensionIdProvider must be specified. | Interface | akka.actor | Akka |
|
| ExtensionKey | This is a one-stop-shop if all you want is an extension which is constructed with the ExtendedActorSystem as its only constructor argument: | Class | akka.actor | Akka |
|
| ExtensionRegistry | A table of known extensions, searchable by name or field number. | Class | akka.protobuf | Akka |
|
| ExtensionRegistryLite | Equivalent to ExtensionRegistry but supports only "lite" types. | Class | akka.protobuf | Akka |
|
| FailBarrier | | Class | akka.remote.testconductor | Akka |
|
| FailBarrier$ | | Class | akka.remote.testconductor | Akka |
|
| Failed | | Class | akka.dispatch.sysmsg | Akka |
|
| Failed | Lifecycle signal that is fired when a direct child actor fails. | Class | akka.typed | Akka |
|
| Failed$ | | Class | akka.dispatch.sysmsg | Akka |
|
| Failed$ | The parent of an actor decides upon the fate of a failed child actor by encapsulating its next behavior in one of the four wrappers defined within | Class | akka.typed | Akka |
|
| FailureDetector | A failure detector must be a thread-safe mutable construct that registers heartbeat events of a resource and is able to decide the availability of that monitored resource. | Interface | akka.remote | Akka |
|
| FailureDetector$ | | Class | akka.remote | Akka |
|
| FailureDetectorLoader | Utility class to create FailureDetector instances reflectively. | Class | akka.remote | Akka |
|
| FailureDetectorLoader$ | Utility class to create FailureDetector instances reflectively. | Class | akka.remote | Akka |
|
| FailureDetectorRegistry | Interface for a registry of Akka failure detectors. | Interface | akka.remote | Akka |
|
| FailureInjectorException | | Class | akka.remote.transport | Akka |
|
| FailureInjectorException$ | | Class | akka.remote.transport | Akka |
|
| FailureInjectorHandle | | Class | akka.remote.transport | Akka |
|
| FailureInjectorHandle$ | | Class | akka.remote.transport | Akka |
|
| FailureInjectorProvider | | Class | akka.remote.transport | Akka |
|
| FailureInjectorTransportAdapter | | Class | akka.remote.transport | Akka |
|
| FailureInjectorTransportAdapter$ | | Class | akka.remote.transport | Akka |
|
| FailureResult | | Class | akka.camel | Akka |
|
| FailureResult$ | | Class | akka.camel | Akka |
|
| FastMerge | Optimization for add/remove followed by merge and merge should just fast forward to It's like a cache between calls of the same thread, you can think of it as a thread local. | Interface | akka.cluster.ddata | Akka |
|
| FaultHandling | Do create the actor in response to a failure. | Interface | akka.actor.dungeon | Akka |
|
| FI | Class that encapsulates all the Functional Interfaces used for creating partial functions. | Class | akka.japi.pf | Akka |
|
| Filter | Java API (not recommended): Callback for the Future. | Class | akka.dispatch | Akka |
|
| Filter$ | Java API (not recommended): Callback for the Future. | Class | akka.dispatch | Akka |
|
| FirstSeedNodeProcess | Used only for the first seed node. | Class | akka.cluster | Akka |
|
| Flag | | Class | akka.cluster.ddata | Akka |
|
| Flag$ | | Class | akka.cluster.ddata | Akka |
|
| FlagKey | | Class | akka.cluster.ddata | Akka |
|
| FlagKey$ | | Class | akka.cluster.ddata | Akka |
|
| FlightAppModels | | Class | docs.persistence.proto | Akka |
|
| Foreach | Callback for the Future. | Class | akka.dispatch | Akka |
|
| ForkJoinExecutorConfigurator | | Class | akka.dispatch | Akka |
|
| ForkJoinExecutorConfigurator$ | | Class | akka.dispatch | Akka |
|
| FromConfig | Java API: Router configuration which has no default, i. | Class | akka.routing | Akka |
|
| FromConfig$ | Router configuration which has no default, i. | Class | akka.routing | Akka |
|
| FSM | Finite State Machine actor trait. | Interface | akka.actor | Akka |
|
| FSM$ | | Class | akka.actor | Akka |
|
| FSMStateFunctionBuilder | Builder used to create a partial function for FSM. | Class | akka.japi.pf | Akka |
|
| FSMStateFunctionBuilder | Builder used to create a partial function for FSM. | Class | akka.persistence.fsm.japi.pf | Akka |
|
| FSMStopBuilder | Builder used to create a partial function for FSM. | Class | akka.japi.pf | Akka |
|
| FSMStopBuilder | Builder used to create a partial function for FSM. | Class | akka.persistence.fsm.japi.pf | Akka |
|
| FSMTransitionHandlerBuilder | Builder used to create a partial function for FSM. | Class | akka.japi.pf | Akka |
|
| Function | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function10 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function11 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function12 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function13 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function14 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function15 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function16 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function17 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function18 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function19 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function2 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function2 | A Function interface. | Interface | akka.japi | Akka |
|
| Function20 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function21 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function22 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function3 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function4 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function5 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function6 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function7 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function8 | A Function interface. | Interface | akka.japi.function | Akka |
|
| Function9 | A Function interface. | Interface | akka.japi.function | Akka |
|
| FutureRef | A combination of a Future and an ActorRef associated with it, which points to an actor performing a task which will eventually resolve the Future. | Interface | akka.pattern | Akka |
|
| FutureRef$ | | Class | akka.pattern | Akka |
|
| FutureRefImpl | | Class | akka.pattern | Akka |
|
| Futures | | Class | akka.dispatch | Akka |
|
| Futures$ | | Class | akka.dispatch | Akka |
|
| FutureTimeoutSupport | | Interface | akka.pattern | Akka |
|
| GCounter | | Class | akka.cluster.ddata | Akka |
|
| GCounter$ | | Class | akka.cluster.ddata | Akka |
|
| GCounterKey | | Class | akka.cluster.ddata | Akka |
|
| GCounterKey$ | | Class | akka.cluster.ddata | Akka |
|
| GeneratedMessage | All generated protocol message classes extend this class. | Class | akka.protobuf | Akka |
|
| GeneratedMessageLite | Lite version of GeneratedMessage. | Class | akka.protobuf | Akka |
|
| GetAddress | | Class | akka.remote.testconductor | Akka |
|
| GetAddress$ | | Class | akka.remote.testconductor | Akka |
|
| GetRoutees | Sending this message to a router will make it send back its currently used routees. | Class | akka.routing | Akka |
|
| GetRoutees$ | | Class | akka.routing | Akka |
|
| Gossip | | Class | akka.cluster | Akka |
|
| Gossip$ | | Class | akka.cluster | Akka |
|
| GossipEnvelope | Envelope adding a sender and receiver address to the gossip. | Class | akka.cluster | Akka |
|
| GossipEnvelope$ | | Class | akka.cluster | Akka |
|
| GossipOverview | Represents the overview of the cluster, holds the cluster convergence table and set with unreachable nodes. | Class | akka.cluster | Akka |
|
| GossipOverview$ | | Class | akka.cluster | Akka |
|
| GossipStats | | Class | akka.cluster | Akka |
|
| GossipStats$ | | Class | akka.cluster | Akka |
|
| GossipStatus | When there are no known changes to the node ring a GossipStatus initiates a gossip chat between two members. | Class | akka.cluster | Akka |
|
| GossipStatus$ | | Class | akka.cluster | Akka |
|
| GracefulStopSupport | scala. | Interface | akka.pattern | Akka |
|
| Group | RouterConfig for router actor with routee actors that are created external to the router and the router sends messages to the specified path using actor selection, | Interface | akka.routing | Akka |
|
| GroupBase | Java API: Base class for custom router GroupSee Also:Serialized Form | Class | akka.routing | Akka |
|
| GSet | | Class | akka.cluster.ddata | Akka |
|
| GSet$ | | Class | akka.cluster.ddata | Akka |
|
| GSetKey | | Class | akka.cluster.ddata | Akka |
|
| GSetKey$ | | Class | akka.cluster.ddata | Akka |
|
| HandshakeInfo | | Class | akka.remote.transport | Akka |
|
| HandshakeInfo$ | | Class | akka.remote.transport | Akka |
|
| HashCode | Set of methods which allow easy implementation of hashCode. | Class | akka.util | Akka |
|
| HashCode$ | Set of methods which allow easy implementation of hashCode. | Class | akka.util | Akka |
|
| HasSequenceNumber | Messages that are to be buffered in AckedSendBuffer or AckedReceiveBuffer has to implement this interface to provide the sequence needed by the buffers. | Interface | akka.remote | Akka |
|
| HasSequenceNumber$ | | Class | akka.remote | Akka |
|
| HeapMetricsSelector | MetricsSelector that uses the heap metrics. | Class | akka.cluster.metrics | Akka |
|
| HeapMetricsSelector | MetricsSelector that uses the heap metrics. | Class | akka.cluster.routing | Akka |
|
| HeapMetricsSelector$ | MetricsSelector that uses the heap metrics. | Class | akka.cluster.metrics | Akka |
|
| HeapMetricsSelector$ | MetricsSelector that uses the heap metrics. | Class | akka.cluster.routing | Akka |
|
| HeartbeatHistory | See Also:Serialized FormCreate an empty HeartbeatHistory, without any history. | Class | akka.remote | Akka |
|
| HeartbeatHistory$ | | Class | akka.remote | Akka |
|
| HeartbeatNodeRing | Data structure for picking heartbeat receivers. | Class | akka.cluster | Akka |
|
| HeartbeatNodeRing$ | | Class | akka.cluster | Akka |
|
| Hello | First message of connection sets names straight. | Class | akka.remote.testconductor | Akka |
|
| Hello$ | | Class | akka.remote.testconductor | Akka |
|
| Helpers | | Class | akka.util | Akka |
|
| Helpers$ | | Class | akka.util | Akka |
|
| HopelessAssociation | | Class | akka.remote | Akka |
|
| HopelessAssociation$ | | Class | akka.remote | Akka |
|
| Identify | A message all Actors will understand, that when processed will reply with ActorIdentity containing the ActorRef. | Class | akka.actor | Akka |
|
| Identify$ | | Class | akka.actor | Akka |
|
| IdentityEventAdapter | No-op model adapter which passes through the incoming events as-is. | Class | akka.persistence.journal | Akka |
|
| IdentityEventAdapter$ | No-op model adapter which passes through the incoming events as-is. | Class | akka.persistence.journal | Akka |
|
| IdentityEventAdapters | | Class | akka.persistence.journal | Akka |
|
| IdentityEventAdapters$ | | Class | akka.persistence.journal | Akka |
|
| IllegalActorStateException | IllegalActorStateException is thrown when a core invariant in the Actor implementation has been violated. | Class | akka.actor | Akka |
|
| IllegalActorStateException$ | | Class | akka.actor | Akka |
|
| InboundMessageDispatcher | | Interface | akka.remote | Akka |
|
| Inbox | | Interface | akka.actor.dsl | Akka |
|
| Inbox | An Inbox is an actor-like object which is interrogated from the outside. | Class | akka.actor | Akka |
|
| Inbox | | Class | akka.typed | Akka |
|
| Inbox$ | | Class | akka.actor.dsl | Akka |
|
| Inbox$ | | Class | akka.actor | Akka |
|
| Inbox$ | | Class | akka.typed | Akka |
|
| Index | An implementation of a ConcurrentMultiMap Adds/remove is serialized over the specified key | Class | akka.util | Akka |
|
| IndirectActorProducer | This interface defines a class of actor creation strategies deviating from the usual default of just reflectively instantiating the Actor | Interface | akka.actor | Akka |
|
| IndirectActorProducer$ | | Class | akka.actor | Akka |
|
| Inet | | Class | akka.io | Akka |
|
| Inet$ | | Class | akka.io | Akka |
|
| InetAddressDnsProvider | | Class | akka.io | Akka |
|
| InetAddressDnsResolver | | Class | akka.io | Akka |
|
| InfoFilter | Filter which matches Info events, if they satisfy the given criteria: source, if given, applies a filter on the event’s originmessage applies a filter on the event’s message (either with String. | Class | akka.testkit | Akka |
|
| InfoFilter$ | | Class | akka.testkit | Akka |
|
| InmemJournal | In-memory journal for testing purposes only. | Class | akka.persistence.journal.inmem | Akka |
|
| InmemMessages | | Interface | akka.persistence.journal.inmem | Akka |
|
| InmemStore | | Class | akka.persistence.journal.inmem | Akka |
|
| Internal | The classes contained within are used internally by the Protocol Buffer library and generated message implementations. | Class | akka.protobuf | Akka |
|
| InternalActorRef | Internal trait for assembling all the functionality needed internally on ActorRefs. | Class | akka.actor | Akka |
|
| InternalClusterAction | | Class | akka.cluster | Akka |
|
| InternalClusterAction$ | | Class | akka.cluster | Akka |
|
| InternetSeedGenerator | | Class | akka.remote.security.provider | Akka |
|
| InternetSeedGenerator$ | Seed generator that maintains multiple strategies for seed generation and will delegate to the best one available for the | Class | akka.remote.security.provider | Akka |
|
| InvalidActorNameException | An InvalidActorNameException is thrown when you try to convert something, usually a String, to an Actor name which doesn't validate. | Class | akka.actor | Akka |
|
| InvalidActorNameException$ | | Class | akka.actor | Akka |
|
| InvalidAssociation | | Class | akka.remote | Akka |
|
| InvalidAssociation$ | | Class | akka.remote | Akka |
|
| InvalidMessageException | InvalidMessageException is thrown when an invalid message is sent to an Actor; Currently only null is an invalid message. | Class | akka.actor | Akka |
|
| InvalidMessageException$ | | Class | akka.actor | Akka |
|
| InvalidProtocolBufferException | Thrown when a protocol message being parsed is invalid in some way, e. | Class | akka.protobuf | Akka |
|
| IO | Entry point to Akka’s IO layer. | Class | akka.io | Akka |
|
| IO$ | Entry point to Akka’s IO layer. | Class | akka.io | Akka |
|
| japi | This class contains bridge classes between Scala and Java. | Class | akka.dispatch | Akka |
|
| JAPI | | Class | akka.japi | Akka |
|
| japi$ | This class contains bridge classes between Scala and Java. | Class | akka.dispatch | Akka |
|
| JavaDurationConverters | | Class | akka.util | Akka |
|
| JavaDurationConverters$ | | Class | akka.util | Akka |
|
| JavaJournalPerfSpec | Java / JUnit consumable equivalent of JournalPerfSpec and JournalSpec. | Class | akka.persistence.japi.journal | Akka |
|
| JavaJournalSpec | Java / JUnit API for JournalSpec. | Class | akka.persistence.japi.journal | Akka |
|
| JavaLogger | java. | Class | akka.contrib.jul | Akka |
|
| JavaLogging | Makes the Akka Logging API available as the log field, using java. | Interface | akka.contrib.jul | Akka |
|
| JavaLoggingAdapter | java. | Interface | akka.contrib.jul | Akka |
|
| JavaPartialFunction | Helper for implementing a *pure* partial function: it will possibly be invoked multiple times for a single “application”, because its only abstract | Class | akka.japi | Akka |
|
| JavaPartialFunction$ | | Class | akka.japi | Akka |
|
| JavaSerializer | | Class | akka.serialization | Akka |
|
| JavaSerializer$ | | Class | akka.serialization | Akka |
|
| JavaSnapshotStoreSpec | This spec aims to verify custom akka-persistence SnapshotStore implementations. | Class | akka.persistence.japi.snapshot | Akka |
|
| JavaTestKit | Java API: Test kit for testing actors. | Class | akka.testkit | Akka |
|
| JmxMetricsCollector | Loads JVM and system metrics through JMX monitoring beans. | Class | akka.cluster | Akka |
|
| JmxMetricsCollector | Loads JVM and system metrics through JMX monitoring beans. | Class | akka.cluster.metrics | Akka |
|
| JoinSeedNodeProcess | Sends InitJoin to all seed nodes (except itself) and expect InitJoinAck reply back. | Class | akka.cluster | Akka |
|
| JournalCapabilityFlags | When true enables tests which check if the Journal properly rejects writes of objects which are not java. | Interface | akka.persistence | Akka |
|
| JournalPerfSpec | This spec measures execution times of the basic operations that an PersistentActor provides, using the provided Journal (plugin). | Class | akka.persistence.journal | Akka |
|
| JournalPerfSpec$ | | Class | akka.persistence.journal | Akka |
|
| JournalProtocol | Messages exchanged between persistent actors, views and a journal. | Class | akka.persistence | Akka |
|
| JournalProtocol$ | Messages exchanged between persistent actors, views and a journal. | Class | akka.persistence | Akka |
|
| JournalSpec | This spec aims to verify custom akka-persistence Journal implementations. | Class | akka.persistence.journal | Akka |
|
| JournalSpec$ | | Class | akka.persistence.journal | Akka |
|
| JSerializer | Java API for creating a Serializer: make sure to include a constructor which takes exactly one argument of type ExtendedActorSystem, because | Class | akka.serialization | Akka |
|
| Key | Key for the key-value data in Replicator. | Class | akka.cluster.ddata | Akka |
|
| Key | | Class | akka.persistence.journal.leveldb | Akka |
|
| Key$ | | Class | akka.cluster.ddata | Akka |
|
| Key$ | | Class | akka.persistence.journal.leveldb | Akka |
|
| Kill | | Class | akka.actor | Akka |
|
| Kill$ | A message all Actors will understand, that when processed will make the Actor throw an ActorKilledException, which will trigger supervision. | Class | akka.actor | Akka |
|
| LatestFirstSystemMessageList | Value class supporting list operations on system messages. | Class | akka.dispatch.sysmsg | Akka |
|
| LatestFirstSystemMessageList$ | | Class | akka.dispatch.sysmsg | Akka |
|
| LazyStringArrayList | An implementation of LazyStringList that wraps an ArrayList. | Class | akka.protobuf | Akka |
|
| LazyStringList | An interface extending List that also provides access to the items of the list as UTF8-encoded ByteString objects. | Interface | akka.protobuf | Akka |
|
| LeveldbIdMapping | LevelDB backed persistent mapping of String-based persistent actor ids to numeric ids. | Interface | akka.persistence.journal.leveldb | Akka |
|
| LeveldbJournal | Journal backed by a local LevelDB store. | Class | akka.persistence.journal.leveldb | Akka |
|
| LeveldbJournal$ | | Class | akka.persistence.journal.leveldb | Akka |
|
| LeveldbReadJournal | Java API: ReadJournal implementation for LevelDB. | Class | akka.persistence.query.journal.leveldb.javadsl | Akka |
|
| LeveldbReadJournal | Scala API ReadJournal implementation for LevelDB. | Class | akka.persistence.query.journal.leveldb.scaladsl | Akka |
|
| LeveldbReadJournal$ | | Class | akka.persistence.query.journal.leveldb.javadsl | Akka |
|
| LeveldbReadJournal$ | | Class | akka.persistence.query.journal.leveldb.scaladsl | Akka |
|
| LeveldbReadJournalProvider | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| LeveldbRecovery | LevelDB backed message replay and sequence number recovery. | Interface | akka.persistence.journal.leveldb | Akka |
|
| LeveldbStore | | Interface | akka.persistence.journal.leveldb | Akka |
|
| LightArrayRevolverScheduler | This scheduler implementation is based on a revolving wheel of buckets, like Netty’s HashedWheelTimer, which it advances at a fixed tick rate and | Class | akka.actor | Akka |
|
| LightArrayRevolverScheduler$ | | Class | akka.actor | Akka |
|
| LineNumbers | This is a minimized byte-code parser that concentrates exclusively on line numbers and source file extraction. | Class | akka.util | Akka |
|
| LineNumbers$ | This is a minimized byte-code parser that concentrates exclusively on line numbers and source file extraction. | Class | akka.util | Akka |
|
| Listen | | Class | akka.routing | Akka |
|
| Listen$ | | Class | akka.routing | Akka |
|
| Listeners | Listeners is a generic trait to implement listening capability on an Actor. | Interface | akka.routing | Akka |
|
| LiveEventsByPersistenceIdPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| LiveEventsByTagPublisher | | Class | akka.persistence.query.journal.leveldb | Akka |
|
| LocalActorRef | Local (serializable) ActorRef that is used when referencing the Actor on its "home" node. | Class | akka.actor | Akka |
|
| LocalActorRefProvider | Local ActorRef provider. | Class | akka.actor | Akka |
|
| LocalActorRefProvider$ | | Class | akka.actor | Akka |
|
| LocalRef | | Interface | akka.actor | Akka |
|
| LocalScope | | Class | akka.actor | Akka |
|
| LocalScope$ | The Local Scope is the default one, which is assumed on all deployments which do not set a different scope. | Class | akka.actor | Akka |
|
| LocalSnapshotStore | Local filesystem backed snapshot store. | Class | akka.persistence.snapshot.local | Akka |
|
| Logger | | Class | akka.event.slf4j | Akka |
|
| Logger$ | | Class | akka.event.slf4j | Akka |
|
| LoggerMailbox | | Class | akka.event | Akka |
|
| LoggerMailboxType | | Class | akka.event | Akka |
|
| Logging | Main entry point for Akka logging: log levels and message types (aka channels) defined for the main transport medium, the main event bus. | Class | akka.event | Akka |
|
| Logging$ | Main entry point for Akka logging: log levels and message types (aka channels) defined for the main transport medium, the main event bus. | Class | akka.event | Akka |
|
| LoggingAdapter | Logging wrapper to make nicer and optimize: provide template versions which evaluate . | Interface | akka.event | Akka |
|
| LoggingBus | This trait brings log level handling to the EventStream: it reads the log levels for the initial logging (StandardOutLogger) and the loggers & level | Interface | akka.event | Akka |
|
| LoggingFilter | Filter of log events that is used by the LoggingAdapter before publishing log events to the eventStream. | Interface | akka.event | Akka |
|
| LoggingFSM | Stackable trait for FSM which adds a rolling event log and debug logging capabilities (analogous to LoggingReceive). | Interface | akka.actor | Akka |
|
| LoggingPersistentFSM | Stackable trait for FSM which adds a rolling event log and debug logging capabilities (analogous to LoggingReceive). | Interface | akka.persistence.fsm | Akka |
|
| LoggingReceive | This decorator adds invocation logging to a Receive function. | Class | akka.event | Akka |
|
| LoggingReceive$ | | Class | akka.event | Akka |
|
| LogSource | This trait defines the interface to be provided by a “log source formatting rule” as used by Logging’s apply/create method. | Interface | akka.event | Akka |
|
| LogSource$ | This object holds predefined formatting rules for log sources. | Class | akka.event | Akka |
|
| LookupClassification | Maps Subscribers to Classifiers using equality on Classifier to store a Set of Subscribers (hence the need for compareSubscribers) Maps Events to Classifiers through the classify-method (so it knows who to publish to) | Interface | akka.event | Akka |
|
| LookupEventBus | Java API: See documentation for LookupClassification E is the Event type | Class | akka.event.japi | Akka |
|
| LWWMap | Specialized ORMap with LWWRegister values. | Class | akka.cluster.ddata | Akka |
|
| LWWMap$ | | Class | akka.cluster.ddata | Akka |
|
| LWWMapKey | | Class | akka.cluster.ddata | Akka |
|
| LWWMapKey$ | | Class | akka.cluster.ddata | Akka |
|
| LWWRegister | It is described in the paper A comprehensive study of Convergent and Commutative Replicated Data Types. | Class | akka.cluster.ddata | Akka |
|
| LWWRegister$ | | Class | akka.cluster.ddata | Akka |
|
| LWWRegisterKey | | Class | akka.cluster.ddata | Akka |
|
| LWWRegisterKey$ | | Class | akka.cluster.ddata | Akka |
|
| Mailbox | Mailbox and InternalMailbox is separated in two classes because ActorCell is needed for implementation, but can't be exposed to user defined mailbox subclasses. | Class | akka.dispatch | Akka |
|
| Mailbox$ | | Class | akka.dispatch | Akka |
|
| Mailboxes | | Class | akka.dispatch | Akka |
|
| Mailboxes$ | | Class | akka.dispatch | Akka |
|
| MailboxType | MailboxType is a factory to create MessageQueues for an optionally provided ActorContext. | Interface | akka.dispatch | Akka |
|
| Main | Main class for running the microkernel. | Class | akka.kernel | Akka |
|
| Main | Main class to start an ActorSystem with one top level application supervisor actor. | Class | akka | Akka |
|
| Main$ | Main class for running the microkernel. | Class | akka.kernel | Akka |
|
| Main$ | Main class to start an ActorSystem with one top level application supervisor actor. | Class | akka | Akka |
|
| ManagedActorClassification | Maps ActorRefs to ActorRefs to form an EventBus where ActorRefs can listen to other ActorRefs. | Interface | akka.event | Akka |
|
| ManagedActorEventBus | Java API: See documentation for ManagedActorClassification An EventBus where the Subscribers are ActorRefs and the Classifier is ActorRef | Class | akka.event.japi | Akka |
|
| ManyVersionVector | | Class | akka.cluster.ddata | Akka |
|
| ManyVersionVector$ | | Class | akka.cluster.ddata | Akka |
|
| Mapper | Callback for the Future. | Class | akka.dispatch | Akka |
|
| Match | | Class | akka.japi.pf | Akka |
|
| MayVerb | | Interface | akka.persistence.scalatest | Akka |
|
| MayVerb$ | | Class | akka.persistence.scalatest | Akka |
|
| Member | Represents the address, current status, and roles of a cluster member node. | Class | akka.cluster | Akka |
|
| Member$ | Module with factory and ordering methods for Member instances. | Class | akka.cluster | Akka |
|
| MemberStatus | Defines the current status of a cluster member node Can be one of: Joining, Up, Leaving, Exiting and Down. | Class | akka.cluster | Akka |
|
| MemberStatus$ | | Class | akka.cluster | Akka |
|
| Message | Abstract interface implemented by Protocol Message objects. | Interface | akka.protobuf | Akka |
|
| MessageContainerSerializer | | Class | akka.remote.serialization | Akka |
|
| MessageDispatcher | | Class | akka.dispatch | Akka |
|
| MessageDispatcher$ | | Class | akka.dispatch | Akka |
|
| MessageDispatcherConfigurator | Base class to be used for hooking in new dispatchers into Dispatchers. | Class | akka.dispatch | Akka |
|
| MessageFormats | | Class | akka.persistence.serialization | Akka |
|
| MessageLite | Abstract interface implemented by Protocol Message objects. | Interface | akka.protobuf | Akka |
|
| MessageLiteOrBuilder | Base interface for methods common to MessageLite and MessageLite. | Interface | akka.protobuf | Akka |
|
| MessageOrBuilder | Base interface for methods common to Message and Message. | Interface | akka.protobuf | Akka |
|
| MessageQueue | A MessageQueue is one of the core components in forming an Akka Mailbox. | Interface | akka.dispatch | Akka |
|
| MessageResult | | Class | akka.camel | Akka |
|
| MessageResult$ | | Class | akka.camel | Akka |
|
| MessageSerializer | Protobuf serializer for ClusterMetricsMessage types. | Class | akka.cluster.metrics.protobuf | Akka |
|
| MessageSerializer | Protobuf serializer for PersistentRepr, AtLeastOnceDelivery and PersistentFSM. | Class | akka.persistence.serialization | Akka |
|
| MessageSerializer | | Class | akka.remote | Akka |
|
| MessageSerializer$ | | Class | akka.remote | Akka |
|
| MessageWrapper | INTERNAL API. | Class | akka.typed | Akka |
|
| Metric | Equality of Metric is based on its name. | Class | akka.cluster | Akka |
|
| Metric | Equality of Metric is based on its name. | Class | akka.cluster.metrics | Akka |
|
| Metric$ | Factory for creating valid Metric instances. | Class | akka.cluster | Akka |
|
| Metric$ | Factory for creating valid Metric instances. | Class | akka.cluster.metrics | Akka |
|
| MetricNumericConverter | Encapsulates evaluation of validity of metric values, conversion of an actual metric value to a Metric for consumption by subscribed cluster entities. | Interface | akka.cluster | Akka |
|
| MetricNumericConverter | Encapsulates evaluation of validity of metric values, conversion of an actual metric value to a Metric for consumption by subscribed cluster entities. | Interface | akka.cluster.metrics | Akka |
|
| MetricsCollector | Implementations of cluster system metrics collectors extend this trait. | Interface | akka.cluster.metrics | Akka |
|
| MetricsCollector | Samples and collects new data points. | Interface | akka.cluster | Akka |
|
| MetricsCollector$ | Factory to create configured MetricsCollector. | Class | akka.cluster.metrics | Akka |
|
| MetricsCollector$ | Factory to create configured MetricsCollector. | Class | akka.cluster | Akka |
|
| MetricsGossip | | Class | akka.cluster.metrics | Akka |
|
| MetricsGossip | | Class | akka.cluster | Akka |
|
| MetricsGossip$ | | Class | akka.cluster.metrics | Akka |
|
| MetricsGossip$ | | Class | akka.cluster | Akka |
|
| MetricsGossipEnvelope | Envelope adding a sender address to the cluster metrics gossip. | Class | akka.cluster.metrics | Akka |
|
| MetricsGossipEnvelope | Envelope adding a sender address to the gossip. | Class | akka.cluster | Akka |
|
| MetricsGossipEnvelope$ | | Class | akka.cluster.metrics | Akka |
|
| MetricsGossipEnvelope$ | | Class | akka.cluster | Akka |
|
| MetricsSelector | A MetricsSelector is responsible for producing weights from the node metrics. | Interface | akka.cluster.metrics | Akka |
|
| MetricsSelector | A MetricsSelector is responsible for producing weights from the node metrics. | Interface | akka.cluster.routing | Akka |
|
| MetricsSelector$ | | Class | akka.cluster.metrics | Akka |
|
| MetricsSelector$ | | Class | akka.cluster.routing | Akka |
|
| MinimalActorRef | Trait for ActorRef implementations where all methods contain default stubs. | Interface | akka.actor | Akka |
|
| MixMetricsSelector | | Class | akka.cluster.metrics | Akka |
|
| MixMetricsSelector | | Class | akka.cluster.routing | Akka |
|
| MixMetricsSelector$ | Singleton instance of the default MixMetricsSelector, which uses [akka. | Class | akka.cluster.metrics | Akka |
|
| MixMetricsSelector$ | Singleton instance of the default MixMetricsSelector, which uses [akka. | Class | akka.cluster.routing | Akka |
|
| MixMetricsSelectorBase | Base class for MetricsSelector that combines other selectors and aggregates their capacity. | Class | akka.cluster.metrics | Akka |
|
| MixMetricsSelectorBase | Base class for MetricsSelector that combines other selectors and aggregates their capacity. | Class | akka.cluster.routing | Akka |
|
| MonitorableThreadFactory | | Class | akka.dispatch | Akka |
|
| MonitorableThreadFactory$ | | Class | akka.dispatch | Akka |
|
| MsgDecoder | | Class | akka.remote.testconductor | Akka |
|
| MsgEncoder | | Class | akka.remote.testconductor | Akka |
|
| MultiNodeConfig | Configure the role names and participants of the test, including configuration settings. | Class | akka.remote.testkit | Akka |
|
| MultiNodeSpec | Note: To be able to run tests with everything ignored or excluded by tags you must not use testconductor, or helper methods that use testconductor, | Class | akka.remote.testkit | Akka |
|
| MultiNodeSpec$ | | Class | akka.remote.testkit | Akka |
|
| MultiNodeSpecCallbacks | Use this to hook MultiNodeSpec into your test framework lifecycle, either by having your test extend MultiNodeSpec and call these methods or by creating a trait that calls them and then mixing that trait with your test together | Interface | akka.remote.testkit | Akka |
|
| MurmurHash | An object designed to generate well-distributed non-cryptographic hashes. | Class | akka.routing | Akka |
|
| MurmurHash$ | An object designed to generate well-distributed non-cryptographic hashes. | Class | akka.routing | Akka |
|
| NettyClientHelpers | org. | Interface | akka.remote.transport.netty | Akka |
|
| NettyFutureBridge | | Class | akka.remote.transport.netty | Akka |
|
| NettyFutureBridge$ | | Class | akka.remote.transport.netty | Akka |
|
| NettyHelpers | org. | Interface | akka.remote.transport.netty | Akka |
|
| NettyServerHelpers | org. | Interface | akka.remote.transport.netty | Akka |
|
| NettySSLSupport | | Class | akka.remote.transport.netty | Akka |
|
| NettySSLSupport$ | | Class | akka.remote.transport.netty | Akka |
|
| NettyTransport | | Class | akka.remote.transport.netty | Akka |
|
| NettyTransport$ | | Class | akka.remote.transport.netty | Akka |
|
| NettyTransportException | | Class | akka.remote.transport.netty | Akka |
|
| NettyTransportSettings | | Class | akka.remote.transport.netty | Akka |
|
| NettyTransportSettings$ | | Class | akka.remote.transport.netty | Akka |
|
| NoArgsReflectConstructor | | Class | akka.actor | Akka |
|
| Nobody | This is an internal look-up failure token, not useful for anything else. | Class | akka.actor | Akka |
|
| Nobody$ | This is an internal look-up failure token, not useful for anything else. | Class | akka.actor | Akka |
|
| NodeMessageQueue | | Class | akka.dispatch | Akka |
|
| NodeMetrics | The snapshot of current sampled health metrics for any monitored process. | Class | akka.cluster.metrics | Akka |
|
| NodeMetrics | The snapshot of current sampled health metrics for any monitored process. | Class | akka.cluster | Akka |
|
| NodeMetrics$ | | Class | akka.cluster.metrics | Akka |
|
| NodeMetrics$ | | Class | akka.cluster | Akka |
|
| NoLogging | | Class | akka.event | Akka |
|
| NoLogging$ | | Class | akka.event | Akka |
|
| NoMessage | | Class | akka.dispatch.sysmsg | Akka |
|
| NoMessage$ | | Class | akka.dispatch.sysmsg | Akka |
|
| NonBlockingBoundedMailbox | NonBlockingBoundedMailbox is a high-performance, multiple-producer single-consumer, bounded MailboxType, Noteworthy is that it discards overflow as DeadLetters. | Class | akka.dispatch | Akka |
|
| NonBlockingBoundedMailbox$ | | Class | akka.dispatch | Akka |
|
| NonPersistentRepr | Message which can be resequenced by the Journal, but will not be persisted. | Class | akka.persistence | Akka |
|
| NonPersistentRepr$ | | Class | akka.persistence | Akka |
|
| NoopReadEventAdapter | | Class | akka.persistence.journal | Akka |
|
| NoopReadEventAdapter$ | | Class | akka.persistence.journal | Akka |
|
| NoopWriteEventAdapter | | Class | akka.persistence.journal | Akka |
|
| NoopWriteEventAdapter$ | | Class | akka.persistence.journal | Akka |
|
| NoRoutee | Routee that doesn't send the message to any routee. | Class | akka.routing | Akka |
|
| NoRoutee$ | Routee that doesn't send the message to any routee. | Class | akka.routing | Akka |
|
| NoRouter | Routing configuration that indicates no routing; this is also the default value which hence overrides the merge strategy in order to accept values | Class | akka.routing | Akka |
|
| NoRouter$ | | Class | akka.routing | Akka |
|
| NoScopeGiven | This is the default value and as such allows overrides. | Class | akka.actor | Akka |
|
| NoScopeGiven$ | | Class | akka.actor | Akka |
|
| NoSnapshotStore | Used as default snapshot-store in case no other store was configured. | Class | akka.persistence.snapshot | Akka |
|
| NullSerializer | | Class | akka.serialization | Akka |
|
| NullSerializer$ | | Class | akka.serialization | Akka |
|
| OnComplete | Callback for when a Future is completed with either failure or a success SAM (Single Abstract Method) class | Class | akka.dispatch | Akka |
|
| OneForOneStrategy | Applies the fault handling Directive (Resume, Restart, Stop) specified in the Decider to the child actor that failed, as opposed to AllForOneStrategy that applies | Class | akka.actor | Akka |
|
| OneForOneStrategy$ | | Class | akka.actor | Akka |
|
| OneVersionVector | | Class | akka.cluster.ddata | Akka |
|
| OneVersionVector$ | | Class | akka.cluster.ddata | Akka |
|
| Oneway | | Interface | akka.camel | Akka |
|
| OnFailure | Callback for when a Future is completed with a failure SAM (Single Abstract Method) class | Class | akka.dispatch | Akka |
|
| OnlyCauseStackTrace | Mix in this trait to suppress the StackTrace for the instance of the exception but not the cause, scala. | Interface | akka | Akka |
|
| OnMemberStatusChangedListener | The supplied callback will be run, once, when current cluster member come up with the same status. | Class | akka.cluster | Akka |
|
| OnSuccess | Callback for when a Future is completed successfully SAM (Single Abstract Method) class | Class | akka.dispatch | Akka |
|
| Ops | Import the contents of this object to retrofit the typed APIs onto the untyped ActorSystem, ActorContext and | Class | akka.typed | Akka |
|
| Ops$ | Import the contents of this object to retrofit the typed APIs onto the untyped ActorSystem, ActorContext and | Class | akka.typed | Akka |
|
| OptimalSizeExploringResizer | | Interface | akka.routing | Akka |
|
| OptimalSizeExploringResizer$ | | Class | akka.routing | Akka |
|
| Option | This class represents optional values. | Class | akka.japi | Akka |
|
| Option$ | | Class | akka.japi | Akka |
|
| OptionalTests | scala. | Interface | akka.persistence.scalatest | Akka |
|
| OriginalRestartException | This is an extractor for retrieving the original cause (i. | Class | akka.actor | Akka |
|
| OriginalRestartException$ | This is an extractor for retrieving the original cause (i. | Class | akka.actor | Akka |
|
| ORMap | It has similar semantics as an ORSet, but in case of concurrent updates the values are merged, and must therefore be ReplicatedData types themselves. | Class | akka.cluster.ddata | Akka |
|
| ORMap$ | | Class | akka.cluster.ddata | Akka |
|
| ORMapKey | | Class | akka.cluster.ddata | Akka |
|
| ORMapKey$ | | Class | akka.cluster.ddata | Akka |
|
| ORMultiMap | An immutable multi-map implementation. | Class | akka.cluster.ddata | Akka |
|
| ORMultiMap$ | | Class | akka.cluster.ddata | Akka |
|
| ORMultiMapKey | | Class | akka.cluster.ddata | Akka |
|
| ORMultiMapKey$ | | Class | akka.cluster.ddata | Akka |
|
| ORSet | Elements can be added and removed any number of times. | Class | akka.cluster.ddata | Akka |
|
| ORSet$ | | Class | akka.cluster.ddata | Akka |
|
| ORSetKey | | Class | akka.cluster.ddata | Akka |
|
| ORSetKey$ | | Class | akka.cluster.ddata | Akka |
|
| OsgiActorSystemFactory | Factory class to create ActorSystem implementations in an OSGi environment. | Class | akka.osgi | Akka |
|
| OsgiActorSystemFactory$ | | Class | akka.osgi | Akka |
|
| OtherMessageComparator | | Class | akka.cluster.ddata.protobuf | Akka |
|
| OtherMessageComparator$ | | Class | akka.cluster.ddata.protobuf | Akka |
|
| OversizedPayloadException | | Class | akka.remote | Akka |
|
| Pair | Represents a pair (tuple) of two elements. | Class | akka.japi | Akka |
|
| Pair$ | | Class | akka.japi | Akka |
|
| Parser | Abstract interface for parsing Protocol Messages. | Interface | akka.protobuf | Akka |
|
| PathUtils | java. | Interface | akka.actor | Akka |
|
| Patterns | | Class | akka.pattern | Akka |
|
| Patterns$ | | Class | akka.pattern | Akka |
|
| PduCodecException | | Class | akka.remote.transport | Akka |
|
| PeekMailbox | | Class | akka.contrib.mailbox | Akka |
|
| PeekMailboxExtension | | Class | akka.contrib.mailbox | Akka |
|
| PeekMailboxExtension$ | | Class | akka.contrib.mailbox | Akka |
|
| PeekMailboxType | configure the mailbox via dispatcher configuration: peek-dispatcher { | Class | akka.contrib.mailbox | Akka |
|
| Persistence | Persistence extension. | Class | akka.persistence | Akka |
|
| Persistence$ | Persistence extension provider. | Class | akka.persistence | Akka |
|
| PersistenceIdentity | Identification of PersistentActor or PersistentView. | Interface | akka.persistence | Akka |
|
| PersistenceQuery | | Class | akka.persistence.query | Akka |
|
| PersistenceQuery$ | Persistence extension for queries. | Class | akka.persistence.query | Akka |
|
| PersistenceRecovery | Called when the persistent actor is started for the first time. | Interface | akka.persistence | Akka |
|
| PersistenceSettings | Persistence configuration. | Class | akka.persistence | Akka |
|
| PersistentActor | An persistent Actor - can be used to implement command or event sourcing. | Interface | akka.persistence | Akka |
|
| PersistentEnvelope | Marks messages which can be resequenced by the AsyncWriteJournal. | Interface | akka.persistence | Akka |
|
| PersistentFSM | A FSM implementation with persistent state. | Interface | akka.persistence.fsm | Akka |
|
| PersistentFSM$ | | Class | akka.persistence.fsm | Akka |
|
| PersistentFSMBase | Finite State Machine actor trait. | Interface | akka.persistence.fsm | Akka |
|
| PersistentImpl | | Class | akka.persistence | Akka |
|
| PersistentImpl$ | | Class | akka.persistence | Akka |
|
| PersistentRepr | Plugin API: representation of a persistent message in the journal plugin API. | Interface | akka.persistence | Akka |
|
| PersistentRepr$ | | Class | akka.persistence | Akka |
|
| PersistentShard | This actor creates children entity actors on demand that it is told to be responsible for. | Class | akka.cluster.sharding | Akka |
|
| PersistentShardCoordinator | Singleton coordinator that decides where to allocate shards. | Class | akka.cluster.sharding | Akka |
|
| PersistentView | A view replicates the persistent message stream of a PersistentActor. | Interface | akka.persistence | Akka |
|
| PersistentView$ | | Class | akka.persistence | Akka |
|
| PFBuilder | A builder for PartialFunction. | Class | akka.japi.pf | Akka |
|
| PhiAccrualFailureDetector | [http://www. | Class | akka.remote | Akka |
|
| PinnedDispatcher | Dedicates a unique thread for each actor passed in as reference. | Class | akka.dispatch | Akka |
|
| PinnedDispatcherConfigurator | Configurator for creating PinnedDispatcher. | Class | akka.dispatch | Akka |
|
| PipeToSupport | | Interface | akka.pattern | Akka |
|
| Player | The Player is the client component of the TestConductorExt extension. | Interface | akka.remote.testconductor | Akka |
|
| PlayerHandler | This handler only forwards messages received from the conductor to the ClientFSM. | Class | akka.remote.testconductor | Akka |
|
| PluginSpec | | Class | akka.persistence | Akka |
|
| PNCounter | It is described in the paper A comprehensive study of Convergent and Commutative Replicated Data Types. | Class | akka.cluster.ddata | Akka |
|
| PNCounter$ | | Class | akka.cluster.ddata | Akka |
|
| PNCounterKey | | Class | akka.cluster.ddata | Akka |
|
| PNCounterKey$ | | Class | akka.cluster.ddata | Akka |
|
| PNCounterMap | Map of named counters. | Class | akka.cluster.ddata | Akka |
|
| PNCounterMap$ | | Class | akka.cluster.ddata | Akka |
|
| PNCounterMapKey | | Class | akka.cluster.ddata | Akka |
|
| PNCounterMapKey$ | | Class | akka.cluster.ddata | Akka |
|
| PoisonPill | | Class | akka.actor | Akka |
|
| PoisonPill$ | A message all Actors will understand, that when processed will terminate the Actor permanently. | Class | akka.actor | Akka |
|
| Pool | RouterConfig for router actor that creates routees as child actors and removes them from the router if they terminate. | Interface | akka.routing | Akka |
|
| Pool$ | | Class | akka.routing | Akka |
|
| PoolBase | Java API: Base class for custom router PoolSee Also:Serialized Form | Class | akka.routing | Akka |
|
| PoolOverrideUnsetConfig | Used to override unset configuration in a router. | Interface | akka.routing | Akka |
|
| PostRestart | Lifecycle signal that is fired upon restart of the Actor after replacing the behavior with the fresh one (i. | Class | akka.typed | Akka |
|
| PostRestart$ | | Class | akka.typed | Akka |
|
| PostRestartException | A PostRestartException is thrown when constructor or postRestart() method fails during a restart attempt. | Class | akka.actor | Akka |
|
| PostRestartException$ | | Class | akka.actor | Akka |
|
| PostStop | Lifecycle signal that is fired after this actor and all its child actors (transitively) have terminated. | Class | akka.typed | Akka |
|
| PostStop$ | Lifecycle signal that is fired after this actor and all its child actors (transitively) have terminated. | Class | akka.typed | Akka |
|
| Predicate | Java API: Defines a criteria and determines whether the parameter meets this criteria. | Interface | akka.japi.function | Akka |
|
| Predicate | Java API: Defines a criteria and determines whether the parameter meets this criteria. | Interface | akka.japi | Akka |
|
| PreRestart | Lifecycle signal that is fired upon restart of the Actor before replacing the behavior with the fresh one (i. | Class | akka.typed | Akka |
|
| PreRestart$ | | Class | akka.typed | Akka |
|
| PreRestartException | A PreRestartException is thrown when the preRestart() method failed; this exception is not propagated to the supervisor, as it originates from the | Class | akka.actor | Akka |
|
| PreRestartException$ | | Class | akka.actor | Akka |
|
| PreStart | Lifecycle signal that is fired upon creation of the Actor. | Class | akka.typed | Akka |
|
| PreStart$ | Lifecycle signal that is fired upon creation of the Actor. | Class | akka.typed | Akka |
|
| PrettyDuration | | Class | akka.util | Akka |
|
| PrettyDuration$ | | Class | akka.util | Akka |
|
| PriorityGenerator | | Class | akka.dispatch | Akka |
|
| PriorityGenerator$ | | Class | akka.dispatch | Akka |
|
| PriorityQueueStabilizer | PriorityQueueStabilizer wraps a priority queue so that it respects FIFO for elements of equal priority. | Interface | akka.util | Akka |
|
| PriorityQueueStabilizer$ | | Class | akka.util | Akka |
|
| Procedure | A Procedure is like a Function, but it doesn't produce a return value. | Interface | akka.japi.function | Akka |
|
| Procedure10 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure11 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure12 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure13 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure14 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure15 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure16 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure17 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure18 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure19 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure2 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure20 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure21 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure22 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure3 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure4 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure5 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure6 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure7 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure8 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Procedure9 | A Consumer interface. | Interface | akka.japi.function | Akka |
|
| Producer | Mixed in by Actor implementations to produce messages to Camel endpoints. | Interface | akka.camel | Akka |
|
| ProducerRegistrar | Registers Producers. | Class | akka.camel.internal | Akka |
|
| ProducerSupport | Support trait for producing messages to Camel endpoints. | Interface | akka.camel | Akka |
|
| ProducesPushTimeoutSemanticsMailbox | Used to determine mailbox factories which create BoundedMessageQueueSemantics mailboxes, and thus should be validated that the pushTimeOut is greater than 0. | Interface | akka.dispatch | Akka |
|
| PromiseActorRef | Akka private optimized representation of the temporary actor spawned to receive the reply to an "ask" operation. | Class | akka.pattern | Akka |
|
| PromiseActorRef$ | | Class | akka.pattern | Akka |
|
| PromiseRef | A combination of a Promise and an ActorRef associated with it, which points to an actor performing a task which will eventually resolve the Promise. | Interface | akka.pattern | Akka |
|
| PromiseRef$ | | Class | akka.pattern | Akka |
|
| PromiseRefImpl | | Class | akka.pattern | Akka |
|
| Props | | Class | akka.actor | Akka |
|
| Props | Props describe how to dress up a Behavior so that it can become an Actor. | Class | akka.typed | Akka |
|
| Props$ | Factory for Props instances. | Class | akka.actor | Akka |
|
| Props$ | Props describe how to dress up a Behavior so that it can become an Actor. | Class | akka.typed | Akka |
|
| ProtobufDecoder | | Class | akka.remote.testconductor | Akka |
|
| ProtobufEncoder | | Class | akka.remote.testconductor | Akka |
|
| ProtobufSerializer | This Serializer serializes akka. | Class | akka.remote.serialization | Akka |
|
| ProtobufSerializer$ | | Class | akka.remote.serialization | Akka |
|
| Protocol | Messages exchanged between persistent actors, views and a journal/snapshot-store. | Class | akka.persistence | Akka |
|
| Protocol$ | Messages exchanged between persistent actors, views and a journal/snapshot-store. | Class | akka.persistence | Akka |
|
| ProtocolMessageEnum | Interface of useful methods added to all enums generated by the protocolReturn the enum type's descriptor, which contains information | Interface | akka.protobuf | Akka |
|
| ProtocolStateActor | | Class | akka.remote.transport | Akka |
|
| ProtocolStateActor$ | | Class | akka.remote.transport | Akka |
|
| PruningState | | Class | akka.cluster.ddata | Akka |
|
| PruningState$ | | Class | akka.cluster.ddata | Akka |
|
| QuarantinedEvent | | Class | akka.remote | Akka |
|
| QuarantinedEvent$ | | Class | akka.remote | Akka |
|
| QueueBasedMessageQueue | A QueueBasedMessageQueue is a MessageQueue backed by a java. | Interface | akka.dispatch | Akka |
|
| RandomGroup | A router group that randomly selects one of the target routees to send a message to. | Class | akka.routing | Akka |
|
| RandomGroup$ | | Class | akka.routing | Akka |
|
| RandomPool | A router pool that randomly selects one of the target routees to send a message to. | Class | akka.routing | Akka |
|
| RandomPool$ | | Class | akka.routing | Akka |
|
| RandomRoutingLogic | | Class | akka.routing | Akka |
|
| RandomRoutingLogic$ | | Class | akka.routing | Akka |
|
| RARP | | Class | akka.remote | Akka |
|
| RARP$ | | Class | akka.remote | Akka |
|
| Reachability | Immutable data structure that holds the reachability status of subject nodes as seen from observer nodes. | Class | akka.cluster | Akka |
|
| Reachability$ | | Class | akka.cluster | Akka |
|
| ReadAggregator | | Class | akka.cluster.ddata | Akka |
|
| ReadAggregator$ | | Class | akka.cluster.ddata | Akka |
|
| ReadEventAdapter | Facility to convert from and to specialised data models, as may be required by specialized persistence Journals. | Interface | akka.persistence.journal | Akka |
|
| ReadJournal | API for reading persistent events and information derived from stored persistent events. | Interface | akka.persistence.query.javadsl | Akka |
|
| ReadJournal | API for reading persistent events and information derived from stored persistent events. | Interface | akka.persistence.query.scaladsl | Akka |
|
| ReadJournalProvider | A query plugin must implement a class that implements this trait. | Interface | akka.persistence.query | Akka |
|
| ReadWriteAggregator | | Class | akka.cluster.ddata | Akka |
|
| ReadWriteAggregator$ | | Class | akka.cluster.ddata | Akka |
|
| ReceiveBuilder | Used for building a partial function for Actor. | Class | akka.japi.pf | Akka |
|
| ReceivePipeline | Trait implementing Receive Pipeline Pattern. | Interface | akka.contrib.pattern | Akka |
|
| ReceivePipeline$ | | Class | akka.contrib.pattern | Akka |
|
| Receiver | | Class | akka.typed.patterns | Akka |
|
| Receiver$ | | Class | akka.typed.patterns | Akka |
|
| ReceiveTimeout | scala. | Interface | akka.actor.dungeon | Akka |
|
| ReceiveTimeout | | Class | akka.actor | Akka |
|
| ReceiveTimeout | The actor can register for a notification in case no message is received within a given time window, and the signal that is raised in this case is | Class | akka.typed | Akka |
|
| ReceiveTimeout$ | | Class | akka.actor.dungeon | Akka |
|
| ReceiveTimeout$ | When using ActorContext. | Class | akka.actor | Akka |
|
| ReceiveTimeout$ | The actor can register for a notification in case no message is received within a given time window, and the signal that is raised in this case is | Class | akka.typed | Akka |
|
| Receptionist | | Class | akka.typed.patterns | Akka |
|
| Receptionist$ | A Receptionist is an entry point into an Actor hierarchy where select Actors publish their identity together with the protocols that they implement. | Class | akka.typed.patterns | Akka |
|
| Recover | Callback for the Future. | Class | akka.dispatch | Akka |
|
| Recovery | Recovery mode configuration object to be returned in PersistenceRecovery. | Class | akka.persistence | Akka |
|
| Recovery$ | | Class | akka.persistence | Akka |
|
| RecoveryCompleted | | Class | akka.persistence | Akka |
|
| RecoveryCompleted$ | Sent to a PersistentActor when the journal replay has been finished. | Class | akka.persistence | Akka |
|
| Recreate | | Class | akka.dispatch.sysmsg | Akka |
|
| Recreate$ | | Class | akka.dispatch.sysmsg | Akka |
|
| ReentrantGuard | | Class | akka.util | Akka |
|
| Reflect | Collection of internal reflection utilities which may or may not be available (most services specific to HotSpot, but fails gracefully). | Class | akka.util | Akka |
|
| Reflect$ | Collection of internal reflection utilities which may or may not be available (most services specific to HotSpot, but fails gracefully). | Class | akka.util | Akka |
|
| ReflectiveDynamicAccess | This is the default DynamicAccess implementation used by ExtendedActorSystem unless overridden. | Class | akka.actor | Akka |
|
| Registry | Registry for Camel Consumers and Producers. | Class | akka.camel.internal | Akka |
|
| RelativeActorPath | Extractor for so-called “relative actor paths” as in “relative URI”, not in “relative to some actor”. | Class | akka.actor | Akka |
|
| RelativeActorPath$ | Extractor for so-called “relative actor paths” as in “relative URI”, not in “relative to some actor”. | Class | akka.actor | Akka |
|
| ReliableDeliverySupervisor | | Class | akka.remote | Akka |
|
| ReliableDeliverySupervisor$ | | Class | akka.remote | Akka |
|
| ReliableProxy | A ReliableProxy is a means to wrap a remote actor reference in order to obtain certain improved delivery guarantees: | Class | akka.contrib.pattern | Akka |
|
| ReliableProxy$ | | Class | akka.contrib.pattern | Akka |
|
| ReliableProxyDebugLogging | java. | Interface | akka.contrib.pattern | Akka |
|
| RemoteActorRef | Remote ActorRef that is used when referencing the Actor on a different node than its "home" node. | Class | akka.remote | Akka |
|
| RemoteActorRefProvider | Depending on this class is not supported, only the ActorRefProvider interface is supported. | Class | akka.remote | Akka |
|
| RemoteActorRefProvider$ | | Class | akka.remote | Akka |
|
| RemoteConnection | | Class | akka.remote.testconductor | Akka |
|
| RemoteConnection$ | | Class | akka.remote.testconductor | Akka |
|
| RemoteDeployer | | Class | akka.remote | Akka |
|
| RemoteDeploymentWatcher | Responsible for cleaning up child references of remote deployed actors when remote node goes down (jvm crash, network failure), i. | Class | akka.remote | Akka |
|
| RemoteDeploymentWatcher$ | | Class | akka.remote | Akka |
|
| RemoteMetrics | | Interface | akka.remote | Akka |
|
| RemoteMetricsExtension | Extension that keeps track of remote metrics, such as max size of different message types. | Class | akka.remote | Akka |
|
| RemoteMetricsExtension$ | Extension that keeps track of remote metrics, such as max size of different message types. | Class | akka.remote | Akka |
|
| RemoteMetricsOff | | Class | akka.remote | Akka |
|
| RemoteMetricsOn | | Class | akka.remote | Akka |
|
| RemoteRouterConfig | RouterConfig implementation for remote deployment on defined target nodes. | Class | akka.remote.routing | Akka |
|
| RemoteRouterConfig$ | | Class | akka.remote.routing | Akka |
|
| RemoteScope | | Class | akka.remote | Akka |
|
| RemoteScope$ | | Class | akka.remote | Akka |
|
| RemoteSettings | | Class | akka.remote | Akka |
|
| RemoteSystemDaemon | Internal system "daemon" actor for remote internal communication. | Class | akka.remote | Akka |
|
| RemoteTransport | The remote transport is responsible for sending and receiving messages. | Class | akka.remote | Akka |
|
| RemoteTransportException | RemoteTransportException represents a general failure within a RemoteTransport, such as inability to start, wrong configuration etc. | Class | akka.remote | Akka |
|
| RemoteTransportExceptionNoStackTrace | RemoteTransportException without stack trace. | Class | akka.remote | Akka |
|
| RemoteWatcher | Remote nodes with actors that are watched are monitored by this actor to be able to detect network failures and JVM crashes. | Class | akka.remote | Akka |
|
| RemoteWatcher$ | | Class | akka.remote | Akka |
|
| Remoting | | Class | akka.remote | Akka |
|
| Remoting$ | | Class | akka.remote | Akka |
|
| RemotingErrorEvent | | Class | akka.remote | Akka |
|
| RemotingErrorEvent$ | | Class | akka.remote | Akka |
|
| RemotingListenEvent | | Class | akka.remote | Akka |
|
| RemotingListenEvent$ | | Class | akka.remote | Akka |
|
| RemotingShutdownEvent | | Class | akka.remote | Akka |
|
| RemotingShutdownEvent$ | | Class | akka.remote | Akka |
|
| Remove | | Class | akka.remote.testconductor | Akka |
|
| Remove$ | | Class | akka.remote.testconductor | Akka |
|
| RemovedNodePruning | ReplicatedData that has support for pruning of data belonging to a specific node may implement this interface. | Interface | akka.cluster.ddata | Akka |
|
| RemoveInternalClusterShardingData | | Class | akka.cluster.sharding | Akka |
|
| RemoveInternalClusterShardingData$ | Utility program that removes the internal data stored with Akka Persistence by the Cluster Sharding coordinator. | Class | akka.cluster.sharding | Akka |
|
| RemoveRoutee | Remove a specific routee by sending this message to the router. | Class | akka.routing | Akka |
|
| RemoveRoutee$ | | Class | akka.routing | Akka |
|
| RepeatedFieldBuilder | RepeatedFieldBuilder implements a structure that a protocol message uses to hold a repeated field of other protocol messages. | Class | akka.protobuf | Akka |
|
| ReplayFilter | | Class | akka.persistence.journal | Akka |
|
| ReplayFilter$ | Detect corrupt event stream during replay. | Class | akka.persistence.journal | Akka |
|
| ReplayMediator | | Class | akka.persistence.journal | Akka |
|
| ReplicatedData | Interface for implementing a state based convergent replicated data type (CvRDT). | Interface | akka.cluster.ddata | Akka |
|
| ReplicatedDataMessages | | Class | akka.cluster.ddata.protobuf.msg | Akka |
|
| ReplicatedDataSerializer | Protobuf serializer of ReplicatedData. | Class | akka.cluster.ddata.protobuf | Akka |
|
| Replicator | A replicated in-memory data store supporting low latency and high availability The Replicator actor takes care of direct replication and gossip based | Class | akka.cluster.ddata | Akka |
|
| Replicator$ | | Class | akka.cluster.ddata | Akka |
|
| ReplicatorMessages | | Class | akka.cluster.ddata.protobuf.msg | Akka |
|
| ReplicatorMessageSerializer | Protobuf serializer of ReplicatorMessage messages. | Class | akka.cluster.ddata.protobuf | Akka |
|
| ReplicatorMessageSerializer$ | | Class | akka.cluster.ddata.protobuf | Akka |
|
| ReplicatorSettings | param: role Replicas are running on members tagged with this role. | Class | akka.cluster.ddata | Akka |
|
| ReplicatorSettings$ | | Class | akka.cluster.ddata | Akka |
|
| RepointableActorRef | This actor ref starts out with some dummy cell (by default just enqueuing messages into vectors protected by ReentrantLock), it must be initialize()’d | Class | akka.actor | Akka |
|
| RepointableRef | RepointableActorRef (and potentially others) may change their locality at runtime, meaning that isLocal might not be stable. | Interface | akka.actor | Akka |
|
| RequiresMessageQueue | Trait to signal that an Actor requires a certain type of message queue semantics. | Interface | akka.dispatch | Akka |
|
| ResendBufferCapacityReachedException | | Class | akka.remote | Akka |
|
| ResendUnfulfillableException | | Class | akka.remote | Akka |
|
| ResizablePoolActor | | Class | akka.routing | Akka |
|
| ResizablePoolActor$ | | Class | akka.routing | Akka |
|
| ResizablePoolCell | | Class | akka.routing | Akka |
|
| Resizer | | Interface | akka.routing | Akka |
|
| Resizer$ | | Class | akka.routing | Akka |
|
| ResizerInitializationException | | Class | akka.routing | Akka |
|
| Resume | | Class | akka.dispatch.sysmsg | Akka |
|
| Resume$ | | Class | akka.dispatch.sysmsg | Akka |
|
| RoleName | | Class | akka.remote.testconductor | Akka |
|
| RoleName$ | | Class | akka.remote.testconductor | Akka |
|
| RootActorPath | Root of the hierarchy of ActorPaths. | Class | akka.actor | Akka |
|
| RootActorPath$ | | Class | akka.actor | Akka |
|
| RoundRobinGroup | A router group that uses round-robin to select a routee. | Class | akka.routing | Akka |
|
| RoundRobinGroup$ | | Class | akka.routing | Akka |
|
| RoundRobinPool | A router pool that uses round-robin to select a routee. | Class | akka.routing | Akka |
|
| RoundRobinPool$ | | Class | akka.routing | Akka |
|
| RoundRobinRoutingLogic | Uses round-robin to select a routee. | Class | akka.routing | Akka |
|
| RoundRobinRoutingLogic$ | | Class | akka.routing | Akka |
|
| RoutedActorCell | | Class | akka.routing | Akka |
|
| RoutedActorCell$ | | Class | akka.routing | Akka |
|
| RoutedActorRef | A RoutedActorRef is an ActorRef that has a set of connected ActorRef and it uses a Router to send a message to one (or more) of these actors. | Class | akka.routing | Akka |
|
| Routee | Abstraction of a destination for messages routed via a Router. | Interface | akka.routing | Akka |
|
| Routees | Message used to carry information about what routees the router is currently using. | Class | akka.routing | Akka |
|
| Routees$ | | Class | akka.routing | Akka |
|
| Router | For each message that is sent through the router via the route(java. | Class | akka.routing | Akka |
|
| Router$ | | Class | akka.routing | Akka |
|
| RouterActor | | Class | akka.routing | Akka |
|
| RouterConfig | This trait represents a router factory: it produces the actual router actor and creates the routing table (a function which determines the recipients | Interface | akka.routing | Akka |
|
| RouterEnvelope | Only the contained message will be forwarded to the destination, i. | Interface | akka.routing | Akka |
|
| RouterPoolActor | | Class | akka.routing | Akka |
|
| RoutingLogic | The interface of the routing logic that is used in a Router to select destination routed messages. | Interface | akka.routing | Akka |
|
| RpcCallback | Interface for an RPC callback, normally called when an RPC completes. | Interface | akka.protobuf | Akka |
|
| RpcChannel | Abstract interface for an RPC channel. | Interface | akka.protobuf | Akka |
|
| RpcController | An RpcController mediates a single method call. | Interface | akka.protobuf | Akka |
|
| RpcUtil | Grab-bag of utility functions useful when dealing with RPCs. | Class | akka.protobuf | Akka |
|
| SaneRejectedExecutionHandler | The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy by throwing a RejectedExecutionException if the executor isShutdown. | Class | akka.dispatch | Akka |
|
| SaveSnapshotFailure | Sent to a PersistentActor after failed saving of a snapshot. | Class | akka.persistence | Akka |
|
| SaveSnapshotFailure$ | | Class | akka.persistence | Akka |
|
| SaveSnapshotSuccess | Sent to a PersistentActor after successful saving of a snapshot. | Class | akka.persistence | Akka |
|
| SaveSnapshotSuccess$ | | Class | akka.persistence | Akka |
|
| ScalaDSL | This object holds several behavior factories and combinators that can be used to construct Behavior instances. | Class | akka.typed | Akka |
|
| ScalaDSL$ | This object holds several behavior factories and combinators that can be used to construct Behavior instances. | Class | akka.typed | Akka |
|
| ScanningClassification | Maps Classifiers to Subscribers and selects which Subscriber should receive which publication through scanning through all Subscribers through the matches(classifier, event) method | Interface | akka.event | Akka |
|
| ScanningEventBus | Java API: See documentation for ScanningClassification E is the Event type | Class | akka.event.japi | Akka |
|
| ScatterGatherFirstCompletedGroup | A router group that broadcasts the message to all routees, and replies with the first response. | Class | akka.routing | Akka |
|
| ScatterGatherFirstCompletedGroup$ | | Class | akka.routing | Akka |
|
| ScatterGatherFirstCompletedPool | A router pool that broadcasts the message to all routees, and replies with the first response. | Class | akka.routing | Akka |
|
| ScatterGatherFirstCompletedPool$ | | Class | akka.routing | Akka |
|
| ScatterGatherFirstCompletedRoutees | | Class | akka.routing | Akka |
|
| ScatterGatherFirstCompletedRoutees$ | | Class | akka.routing | Akka |
|
| ScatterGatherFirstCompletedRoutingLogic | Broadcasts the message to all routees, and replies with the first response. | Class | akka.routing | Akka |
|
| ScatterGatherFirstCompletedRoutingLogic$ | | Class | akka.routing | Akka |
|
| Scheduler | An Akka scheduler service. | Interface | akka.actor | Akka |
|
| SchedulerException | This exception is thrown by Scheduler. | Class | akka.actor | Akka |
|
| SchedulerException$ | | Class | akka.actor | Akka |
|
| SchemeAugmenter | addedSchemeIdentifierjava. | Interface | akka.remote.transport | Akka |
|
| Scope | The scope of a Deploy serves two purposes: as a marker for pattern matching the “scope” (i. | Interface | akka.actor | Akka |
|
| SeedSize | From AESCounterRNG API docs: Valid values are 16 (128 bits), 24 (192 bits) and 32 (256 bits). | Class | akka.remote.security.provider | Akka |
|
| SeedSize$ | From AESCounterRNG API docs: Valid values are 16 (128 bits), 24 (192 bits) and 32 (256 bits). | Class | akka.remote.security.provider | Akka |
|
| SelectChildName | | Class | akka.actor | Akka |
|
| SelectChildName$ | | Class | akka.actor | Akka |
|
| SelectChildPattern | | Class | akka.actor | Akka |
|
| SelectChildPattern$ | | Class | akka.actor | Akka |
|
| SelectedSnapshot | Plugin API: a selected snapshot matching SnapshotSelectionCriteria. | Class | akka.persistence | Akka |
|
| SelectedSnapshot$ | | Class | akka.persistence | Akka |
|
| SelectionHandler | | Class | akka.io | Akka |
|
| SelectionHandler$ | | Class | akka.io | Akka |
|
| SelectionHandlerSettings | | Class | akka.io | Akka |
|
| SelectParent | | Class | akka.actor | Akka |
|
| SelectParent$ | | Class | akka.actor | Akka |
|
| SeqNo | | Class | akka.remote | Akka |
|
| SeqNo$ | | Class | akka.remote | Akka |
|
| Serialization | Serialization module. | Class | akka.serialization | Akka |
|
| Serialization$ | | Class | akka.serialization | Akka |
|
| SerializationExtension | SerializationExtension is an Akka Extension to interact with the Serialization that is built into Akka | Class | akka.serialization | Akka |
|
| SerializationExtension$ | SerializationExtension is an Akka Extension to interact with the Serialization that is built into Akka | Class | akka.serialization | Akka |
|
| SerializationSupport | Some useful serialization helper methods. | Interface | akka.cluster.ddata.protobuf | Akka |
|
| SerializedActorRef | Memento pattern for serializing ActorRefs transparentlySee Also:Serialized Form | Class | akka.actor | Akka |
|
| SerializedActorRef$ | | Class | akka.actor | Akka |
|
| SerializedNobody | | Class | akka.actor | Akka |
|
| SerializedSuspendableExecutionContext | This ExecutionContext allows to wrap an underlying ExecutionContext and provide guaranteed serial execution of tasks submitted to it. | Class | akka.util | Akka |
|
| SerializedSuspendableExecutionContext$ | | Class | akka.util | Akka |
|
| Serializer | A Serializer represents a bimap between an object and an array of bytes representing that object. | Interface | akka.serialization | Akka |
|
| SerializerWithStringManifest | A Serializer represents a bimap between an object and an array of bytes representing that object. | Class | akka.serialization | Akka |
|
| Server | | Class | akka.remote.testconductor | Akka |
|
| Server$ | | Class | akka.remote.testconductor | Akka |
|
| ServerFSM | The server part of each client connection is represented by a ServerFSM. | Class | akka.remote.testconductor | Akka |
|
| ServerFSM$ | | Class | akka.remote.testconductor | Akka |
|
| ServerHandler | | Class | akka.remote.transport.netty | Akka |
|
| Service | Abstract base interface for protocol-buffer-based RPC services. | Interface | akka.protobuf | Akka |
|
| ServiceException | Thrown by blocking RPC methods when a failure occurs. | Class | akka.protobuf | Akka |
|
| SeveralRoutees | Routee that sends each message to all routees. | Class | akka.routing | Akka |
|
| SeveralRoutees$ | | Class | akka.routing | Akka |
|
| Shard | This actor creates children entity actors on demand that it is told to beSee Also:ClusterSharding extension | Class | akka.cluster.sharding | Akka |
|
| Shard$ | | Class | akka.cluster.sharding | Akka |
|
| ShardCoordinator | Singleton coordinator that decides where to allocate shards. | Class | akka.cluster.sharding | Akka |
|
| ShardCoordinator$ | | Class | akka.cluster.sharding | Akka |
|
| ShardRegion | This actor creates children entity actors on demand for the shards that it is told to be responsible for. | Class | akka.cluster.sharding | Akka |
|
| ShardRegion$ | | Class | akka.cluster.sharding | Akka |
|
| SharedLeveldbJournal | Journal backed by a SharedLeveldbStore. | Class | akka.persistence.journal.leveldb | Akka |
|
| SharedLeveldbJournal$ | | Class | akka.persistence.journal.leveldb | Akka |
|
| SharedLeveldbStore | A LevelDB store that can be shared by multiple actor systems. | Class | akka.persistence.journal.leveldb | Akka |
|
| ShutDownAssociation | | Class | akka.remote | Akka |
|
| ShutDownAssociation$ | | Class | akka.remote | Akka |
|
| SigarMetricsCollector | Loads metrics through Hyperic SIGAR and JMX monitoring beans. | Class | akka.cluster.metrics | Akka |
|
| SigarMetricsCollector | Loads metrics through Hyperic SIGAR and JMX monitoring beans. | Class | akka.cluster | Akka |
|
| SigarProvider | Provide sigar instance as SigarProxy. | Interface | akka.cluster.metrics | Akka |
|
| SigarProvider$ | | Class | akka.cluster.metrics | Akka |
|
| SimpleDnsCache | | Class | akka.io | Akka |
|
| SimpleDnsCache$ | | Class | akka.io | Akka |
|
| SimpleDnsManager | | Class | akka.io | Akka |
|
| SimpleDnsManager$ | | Class | akka.io | Akka |
|
| SingleConsumerOnlyUnboundedMailbox | | Class | akka.dispatch | Akka |
|
| SingleConsumerOnlyUnboundedMailbox$ | | Class | akka.dispatch | Akka |
|
| SingleEventSeq | | Class | akka.persistence.journal | Akka |
|
| SingleEventSeq$ | | Class | akka.persistence.journal | Akka |
|
| SingleFieldBuilder | SingleFieldBuilder implements a structure that a protocol message uses to hold a single field of another protocol message. | Class | akka.protobuf | Akka |
|
| Slf4jLogger | The thread in which the logging was performed is captured in Mapped Diagnostic Context (MDC) with attribute name "sourceThread". | Class | akka.event.slf4j | Akka |
|
| SLF4JLogging | Base trait for all classes that wants to be able use the SLF4J logging infrastructure. | Interface | akka.event.slf4j | Akka |
|
| Slf4jLoggingFilter | LoggingFilter that uses the log level defined in the SLF4J backend configuration (e. | Class | akka.event.slf4j | Akka |
|
| SmallestMailboxPool | A router pool that tries to send to the non-suspended routee with fewest messages in mailbox. | Class | akka.routing | Akka |
|
| SmallestMailboxPool$ | | Class | akka.routing | Akka |
|
| SmallestMailboxRoutingLogic | Tries to send to the non-suspended routee with fewest messages in mailbox. | Class | akka.routing | Akka |
|
| SmallestMailboxRoutingLogic$ | | Class | akka.routing | Akka |
|
| Snapshot | Wrapper for snapshot data. | Class | akka.persistence.serialization | Akka |
|
| Snapshot$ | | Class | akka.persistence.serialization | Akka |
|
| SnapshotHeader | | Class | akka.persistence.serialization | Akka |
|
| SnapshotHeader$ | | Class | akka.persistence.serialization | Akka |
|
| SnapshotMetadata | param: persistenceId id of persistent actor from which the snapshot was taken. | Class | akka.persistence | Akka |
|
| SnapshotMetadata$ | | Class | akka.persistence | Akka |
|
| SnapshotOffer | Offers a PersistentActor a previously saved snapshot during recovery. | Class | akka.persistence | Akka |
|
| SnapshotOffer$ | | Class | akka.persistence | Akka |
|
| SnapshotProtocol | Defines messages exchanged between persistent actors and a snapshot store. | Class | akka.persistence | Akka |
|
| SnapshotProtocol$ | Defines messages exchanged between persistent actors and a snapshot store. | Class | akka.persistence | Akka |
|
| SnapshotSelectionCriteria | Selection criteria for loading and deleting snapshots. | Class | akka.persistence | Akka |
|
| SnapshotSelectionCriteria$ | | Class | akka.persistence | Akka |
|
| SnapshotSerializer | Snapshot serializer. | Class | akka.persistence.serialization | Akka |
|
| SnapshotSerializer$ | | Class | akka.persistence.serialization | Akka |
|
| SnapshotStore | Java API: abstract snapshot store. | Class | akka.persistence.snapshot.japi | Akka |
|
| SnapshotStore | Abstract snapshot store. | Interface | akka.persistence.snapshot | Akka |
|
| SnapshotStoreSpec | This spec aims to verify custom akka-persistence SnapshotStore implementations. | Class | akka.persistence.snapshot | Akka |
|
| SnapshotStoreSpec$ | | Class | akka.persistence.snapshot | Akka |
|
| Snapshotter | Snapshot API on top of the internal snapshot protocol. | Interface | akka.persistence | Akka |
|
| SocketUtil | Utilities to get free socket address. | Class | akka.testkit | Akka |
|
| SocketUtil$ | Utilities to get free socket address. | Class | akka.testkit | Akka |
|
| SSLSettings | | Class | akka.remote.transport.netty | Akka |
|
| StablePriorityBlockingQueue | StablePriorityBlockingQueue is a blocking priority queue that preserves order for elements of equal priority. | Class | akka.util | Akka |
|
| StablePriorityQueue | StablePriorityQueue is a priority queue that preserves order for elements of equal priority. | Class | akka.util | Akka |
|
| StandardMetrics | Definitions of the built-in standard metrics. | Class | akka.cluster.metrics | Akka |
|
| StandardMetrics | Definitions of the built-in standard metrics. | Class | akka.cluster | Akka |
|
| StandardMetrics$ | Definitions of the built-in standard metrics. | Class | akka.cluster.metrics | Akka |
|
| StandardMetrics$ | Definitions of the built-in standard metrics. | Class | akka.cluster | Akka |
|
| Stash | The Stash trait enables an actor to temporarily stash away messages that can not or should not be handled using the actor's current behavior. | Interface | akka.actor | Akka |
|
| StashFactory | A factory for creating stashes for an actor instance. | Interface | akka.actor | Akka |
|
| StashOverflowException | Is thrown when the size of the Stash exceeds the capacity of the StashSee Also:Serialized Form | Class | akka.actor | Akka |
|
| StashOverflowException$ | | Class | akka.actor | Akka |
|
| StashSupport | Support trait for implementing a stash for an actor instance. | Interface | akka.actor | Akka |
|
| Status | Classes for passing status back to the sender. | Class | akka.actor | Akka |
|
| Status$ | Classes for passing status back to the sender. | Class | akka.actor | Akka |
|
| StopChild | Internal Akka use only, used in implementation of system. | Class | akka.actor | Akka |
|
| StopChild$ | | Class | akka.actor | Akka |
|
| StoppingSupervisorStrategy | | Class | akka.actor | Akka |
|
| StubbedActorContext | An ActorContext for synchronous execution of a Behavior that provides only stubs for the effects an Actor can perform and replaces | Class | akka.typed | Akka |
|
| SubchannelClassification | Classification which respects relationships between channels: subscribing to one channel automatically and idempotently subscribes to all sub-channels. | Interface | akka.event | Akka |
|
| SubchannelEventBus | Java API: See documentation for SubchannelClassification E is the Event type | Class | akka.event.japi | Akka |
|
| Subclassification | Typeclass which describes a classification hierarchy. | Interface | akka.util | Akka |
|
| SubclassifiedIndex | Mutable index which respects sub-class relationships between keys: - adding a key inherits from super-class | Class | akka.util | Akka |
|
| SubclassifiedIndex$ | | Class | akka.util | Akka |
|
| Supervise | | Class | akka.dispatch.sysmsg | Akka |
|
| Supervise$ | | Class | akka.dispatch.sysmsg | Akka |
|
| SupervisorStrategy | An Akka SupervisorStrategy is the policy to apply for crashing children. | Class | akka.actor | Akka |
|
| SupervisorStrategy$ | | Class | akka.actor | Akka |
|
| SupervisorStrategyConfigurator | the top-level guardian actor (/user). | Interface | akka.actor | Akka |
|
| SupervisorStrategyLowPriorityImplicits | Implicit conversion from Seq of Cause-Directive pairs to a Decider. | Interface | akka.actor | Akka |
|
| SuppressedDeadLetter | Similar to DeadLetter with the slight twist of NOT being logged by the default dead letters listener. | Class | akka.actor | Akka |
|
| SuppressedDeadLetter$ | | Class | akka.actor | Akka |
|
| Suspend | | Class | akka.dispatch.sysmsg | Akka |
|
| Suspend$ | | Class | akka.dispatch.sysmsg | Akka |
|
| Switch | | Class | akka.util | Akka |
|
| Switch$ | | Class | akka.util | Akka |
|
| SystemGuardian | | Class | akka.actor | Akka |
|
| SystemGuardian$ | | Class | akka.actor | Akka |
|
| SystemLoadAverageMetricsSelector | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.metrics | Akka |
|
| SystemLoadAverageMetricsSelector | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.routing | Akka |
|
| SystemLoadAverageMetricsSelector$ | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.metrics | Akka |
|
| SystemLoadAverageMetricsSelector$ | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.routing | Akka |
|
| SystemMessage | System messages are handled specially: they form their own queue within each actor’s mailbox. | Interface | akka.dispatch.sysmsg | Akka |
|
| SystemMessageList | Helper companion object for LatestFirstSystemMessageList and EarliestFirstSystemMessageList | Class | akka.dispatch.sysmsg | Akka |
|
| SystemMessageList$ | Helper companion object for LatestFirstSystemMessageList and EarliestFirstSystemMessageList | Class | akka.dispatch.sysmsg | Akka |
|
| SystemMessageQueue | Dequeue all messages from system queue and return them as single-linked list. | Interface | akka.dispatch | Akka |
|
| Tagged | The journal may support tagging of events that are used by the EventsByTag query and it may support specifying the tags via an | Class | akka.persistence.journal | Akka |
|
| Tagged$ | | Class | akka.persistence.journal | Akka |
|
| TailChoppingGroup | A router group with retry logic, intended for cases where a return message is expected in response to a message sent to the routee. | Class | akka.routing | Akka |
|
| TailChoppingGroup$ | | Class | akka.routing | Akka |
|
| TailChoppingPool | A router pool with retry logic, intended for cases where a return message is expected in response to a message sent to the routee. | Class | akka.routing | Akka |
|
| TailChoppingPool$ | | Class | akka.routing | Akka |
|
| TailChoppingRoutees | | Class | akka.routing | Akka |
|
| TailChoppingRoutees$ | | Class | akka.routing | Akka |
|
| TailChoppingRoutingLogic | As each message is sent to the router, the routees are randomly ordered. | Class | akka.routing | Akka |
|
| TailChoppingRoutingLogic$ | | Class | akka.routing | Akka |
|
| TaskInvocation | | Class | akka.dispatch | Akka |
|
| TaskInvocation$ | | Class | akka.dispatch | Akka |
|
| Tcp | TCP Extension for Akka’s IO layer. | Class | akka.io | Akka |
|
| Tcp$ | TCP Extension for Akka’s IO layer. | Class | akka.io | Akka |
|
| TcpAssociationHandle | | Class | akka.remote.transport.netty | Akka |
|
| TcpClientHandler | | Class | akka.remote.transport.netty | Akka |
|
| TcpConnection | Base class for TcpIncomingConnection and TcpOutgoingConnection. | Class | akka.io | Akka |
|
| TcpConnection$ | | Class | akka.io | Akka |
|
| TcpExt | | Class | akka.io | Akka |
|
| TcpHandlers | | Interface | akka.remote.transport.netty | Akka |
|
| TcpIncomingConnection | | Class | akka.io | Akka |
|
| TcpListener | | Class | akka.io | Akka |
|
| TcpListener$ | | Class | akka.io | Akka |
|
| TcpManager | TcpManager is a facade for accepting commands (Tcp. | Class | akka.io | Akka |
|
| TcpMessage | | Class | akka.io | Akka |
|
| TcpMessage$ | | Class | akka.io | Akka |
|
| TcpOutgoingConnection | | Class | akka.io | Akka |
|
| TcpServerHandler | | Class | akka.remote.transport.netty | Akka |
|
| TcpSO | Java API for accessing socket options. | Class | akka.io | Akka |
|
| TcpSO$ | Java API for accessing socket options. | Class | akka.io | Akka |
|
| Terminate | | Class | akka.dispatch.sysmsg | Akka |
|
| Terminate | | Class | akka.remote.testconductor | Akka |
|
| Terminate$ | | Class | akka.dispatch.sysmsg | Akka |
|
| Terminate$ | | Class | akka.remote.testconductor | Akka |
|
| Terminated | When Death Watch is used, the watcher will receive a Terminated(watched) message when watched is terminated. | Class | akka.actor | Akka |
|
| Terminated | Lifecycle signal that is fired when an Actor that was watched has terminated. | Class | akka.typed | Akka |
|
| Terminated$ | | Class | akka.actor | Akka |
|
| Terminated$ | | Class | akka.typed | Akka |
|
| TerminateMsg | | Class | akka.remote.testconductor | Akka |
|
| TerminateMsg$ | | Class | akka.remote.testconductor | Akka |
|
| TestActor | | Class | akka.testkit | Akka |
|
| TestActor$ | | Class | akka.testkit | Akka |
|
| TestActorRef | This special ActorRef is exclusively for use during unit testing in a single-threaded environment. | Class | akka.testkit | Akka |
|
| TestActorRef$ | | Class | akka.testkit | Akka |
|
| TestActors | A collection of common actor patterns used in tests. | Class | akka.testkit | Akka |
|
| TestActors$ | A collection of common actor patterns used in tests. | Class | akka.testkit | Akka |
|
| TestAssociationHandle | | Class | akka.remote.transport | Akka |
|
| TestAssociationHandle$ | | Class | akka.remote.transport | Akka |
|
| TestBarrier | | Class | akka.testkit | Akka |
|
| TestBarrier$ | A cyclic barrier wrapper for use in testing. | Class | akka.testkit | Akka |
|
| TestBarrierTimeoutException | | Class | akka.testkit | Akka |
|
| TestConductor | Access to the TestConductorExt extension: val tc = TestConductor(system) | Class | akka.remote.testconductor | Akka |
|
| TestConductor$ | Access to the TestConductorExt extension: val tc = TestConductor(system) | Class | akka.remote.testconductor | Akka |
|
| TestConductorExt | This binds together the Conductor and Player roles inside an Akka | Class | akka.remote.testconductor | Akka |
|
| TestConductorPipelineFactory | | Class | akka.remote.testconductor | Akka |
|
| TestConductorProtocol | | Class | akka.remote.testconductor | Akka |
|
| TestEvent | to the TestEventListener to install a filter, and UnMute to You should always prefer the filter methods in the package object | Interface | akka.testkit | Akka |
|
| TestEvent$ | to the TestEventFilter to install a filter, and UnMute to You should always prefer the filter methods in the package object | Class | akka.testkit | Akka |
|
| TestEventListener | EventListener for running tests, which allows selectively filtering out expected messages. | Class | akka.testkit | Akka |
|
| TestFSMRef | This is a specialized form of the TestActorRef with support for querying and setting the state of a FSM. | Class | akka.testkit | Akka |
|
| TestFSMRef$ | | Class | akka.testkit | Akka |
|
| TestKit | Test kit for testing actors. | Class | akka.testkit | Akka |
|
| TestKit$ | | Class | akka.testkit | Akka |
|
| TestKitBase | this if inheriting from a concrete class is not possible. | Interface | akka.testkit | Akka |
|
| TestKitExtension | | Class | akka.testkit | Akka |
|
| TestKitExtension$ | | Class | akka.testkit | Akka |
|
| TestKitSettings | | Class | akka.testkit | Akka |
|
| TestLatch | | Class | akka.testkit | Akka |
|
| TestLatch$ | A count down latch wrapper for use in testing. | Class | akka.testkit | Akka |
|
| TestProbe | TestKit-based probe which allows sending, reception and reply. | Class | akka.testkit | Akka |
|
| TestProbe$ | | Class | akka.testkit | Akka |
|
| TestTransport | Transport implementation to be used for testing. | Class | akka.remote.transport | Akka |
|
| TestTransport$ | | Class | akka.remote.transport | Akka |
|
| TextFormat | Provide text parsing and formatting support for proto2 instances. | Class | akka.protobuf | Akka |
|
| ThreadPoolConfig | | Class | akka.dispatch | Akka |
|
| ThreadPoolConfig$ | | Class | akka.dispatch | Akka |
|
| ThreadPoolConfigBuilder | A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutorSee Also:Serialized Form | Class | akka.dispatch | Akka |
|
| ThreadPoolConfigBuilder$ | | Class | akka.dispatch | Akka |
|
| ThreadPoolExecutorConfigurator | | Class | akka.dispatch | Akka |
|
| Throttle | | Class | akka.remote.testconductor | Akka |
|
| Throttle$ | | Class | akka.remote.testconductor | Akka |
|
| ThrottledAssociation | | Class | akka.remote.transport | Akka |
|
| ThrottledAssociation$ | | Class | akka.remote.transport | Akka |
|
| ThrottleMsg | | Class | akka.remote.testconductor | Akka |
|
| ThrottleMsg$ | | Class | akka.remote.testconductor | Akka |
|
| Throttler | | Class | akka.contrib.throttle | Akka |
|
| Throttler$ | | Class | akka.contrib.throttle | Akka |
|
| ThrottlerHandle | | Class | akka.remote.transport | Akka |
|
| ThrottlerHandle$ | | Class | akka.remote.transport | Akka |
|
| ThrottlerManager | | Class | akka.remote.transport | Akka |
|
| ThrottlerManager$ | | Class | akka.remote.transport | Akka |
|
| ThrottlerProvider | | Class | akka.remote.transport | Akka |
|
| ThrottlerTransportAdapter | | Class | akka.remote.transport | Akka |
|
| ThrottlerTransportAdapter$ | | Class | akka.remote.transport | Akka |
|
| Timeout | | Class | akka.util | Akka |
|
| Timeout$ | A Timeout is a wrapper on top of Duration to be more specific about what the duration means. | Class | akka.util | Akka |
|
| TimerBasedThrottler | A throttler that uses a timer to control the message delivery rate. | Class | akka.contrib.throttle | Akka |
|
| TimerBasedThrottler$ | | Class | akka.contrib.throttle | Akka |
|
| ToClient | | Class | akka.remote.testconductor | Akka |
|
| ToClient$ | | Class | akka.remote.testconductor | Akka |
|
| ToServer | | Class | akka.remote.testconductor | Akka |
|
| ToServer$ | | Class | akka.remote.testconductor | Akka |
|
| TransparentExponentialBackoffSupervisor | A supervising actor that restarts a child actor with an exponential back off. | Class | akka.contrib.pattern | Akka |
|
| TransparentExponentialBackoffSupervisor$ | | Class | akka.contrib.pattern | Akka |
|
| Transport | An SPI layer for implementing asynchronous transport mechanisms. | Interface | akka.remote.transport | Akka |
|
| Transport$ | | Class | akka.remote.transport | Akka |
|
| TransportAdapterProvider | | Interface | akka.remote.transport | Akka |
|
| TransportAdapters | | Class | akka.remote.transport | Akka |
|
| TransportAdaptersExtension | | Class | akka.remote.transport | Akka |
|
| TransportAdaptersExtension$ | | Class | akka.remote.transport | Akka |
|
| TryNative | | Class | akka.cluster.metrics | Akka |
|
| TryNative$ | | Class | akka.cluster.metrics | Akka |
|
| Tuple10 | | Class | akka.japi.tuple | Akka |
|
| Tuple10$ | Used to create tuples with 10 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple11 | | Class | akka.japi.tuple | Akka |
|
| Tuple11$ | Used to create tuples with 11 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple12 | | Class | akka.japi.tuple | Akka |
|
| Tuple12$ | Used to create tuples with 12 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple13 | | Class | akka.japi.tuple | Akka |
|
| Tuple13$ | Used to create tuples with 13 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple14 | | Class | akka.japi.tuple | Akka |
|
| Tuple14$ | Used to create tuples with 14 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple15 | | Class | akka.japi.tuple | Akka |
|
| Tuple15$ | Used to create tuples with 15 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple16 | | Class | akka.japi.tuple | Akka |
|
| Tuple16$ | Used to create tuples with 16 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple17 | | Class | akka.japi.tuple | Akka |
|
| Tuple17$ | Used to create tuples with 17 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple18 | | Class | akka.japi.tuple | Akka |
|
| Tuple18$ | Used to create tuples with 18 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple19 | | Class | akka.japi.tuple | Akka |
|
| Tuple19$ | Used to create tuples with 19 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple20 | | Class | akka.japi.tuple | Akka |
|
| Tuple20$ | Used to create tuples with 20 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple21 | | Class | akka.japi.tuple | Akka |
|
| Tuple21$ | Used to create tuples with 21 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple22 | | Class | akka.japi.tuple | Akka |
|
| Tuple22$ | Used to create tuples with 22 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple3 | | Class | akka.japi.tuple | Akka |
|
| Tuple3$ | Used to create tuples with 3 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple4 | | Class | akka.japi.tuple | Akka |
|
| Tuple4$ | Used to create tuples with 4 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple5 | | Class | akka.japi.tuple | Akka |
|
| Tuple5$ | Used to create tuples with 5 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple6 | | Class | akka.japi.tuple | Akka |
|
| Tuple6$ | Used to create tuples with 6 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple7 | | Class | akka.japi.tuple | Akka |
|
| Tuple7$ | Used to create tuples with 7 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple8 | | Class | akka.japi.tuple | Akka |
|
| Tuple8$ | Used to create tuples with 8 elements in Java. | Class | akka.japi.tuple | Akka |
|
| Tuple9 | | Class | akka.japi.tuple | Akka |
|
| Tuple9$ | Used to create tuples with 9 elements in Java. | Class | akka.japi.tuple | Akka |
|
| TwoPhaseSetMessages | | Class | docs.ddata.protobuf.msg | Akka |
|
| TypedActor | This represents the TypedActor Akka Extension, access to the functionality is done through a given ActorSystem. | Class | akka.actor | Akka |
|
| TypedActor$ | This represents the TypedActor Akka Extension, access to the functionality is done through a given ActorSystem. | Class | akka.actor | Akka |
|
| TypedActorExtension | | Class | akka.actor | Akka |
|
| TypedActorFactory | A TypedActorFactory is something that can created TypedActor instances. | Interface | akka.actor | Akka |
|
| TypedCreatorFunctionConsumer | | Class | akka.actor | Akka |
|
| TypedMultiMap | An immutable multi-map that expresses the value type as a type function of the key type. | Class | akka.util | Akka |
|
| TypedMultiMap$ | | Class | akka.util | Akka |
|
| TypedProps | | Class | akka.actor | Akka |
|
| TypedProps$ | TypedProps is a TypedActor configuration object, that is thread safe and fully sharable. | Class | akka.actor | Akka |
|
| Udp | UDP Extension for Akka’s IO layer. | Class | akka.io | Akka |
|
| Udp$ | UDP Extension for Akka’s IO layer. | Class | akka.io | Akka |
|
| UdpAssociationHandle | | Class | akka.remote.transport.netty | Akka |
|
| UdpClientHandler | | Class | akka.remote.transport.netty | Akka |
|
| UdpConnected | UDP Extension for Akka’s IO layer. | Class | akka.io | Akka |
|
| UdpConnected$ | UDP Extension for Akka’s IO layer. | Class | akka.io | Akka |
|
| UdpConnectedExt | | Class | akka.io | Akka |
|
| UdpConnectedManager | | Class | akka.io | Akka |
|
| UdpConnectedMessage | Java API: factory methods for the message types used when communicating with the UdpConnected service. | Class | akka.io | Akka |
|
| UdpConnectedMessage$ | Java API: factory methods for the message types used when communicating with the UdpConnected service. | Class | akka.io | Akka |
|
| UdpConnection | | Class | akka.io | Akka |
|
| UdpExt | | Class | akka.io | Akka |
|
| UdpHandlers | | Interface | akka.remote.transport.netty | Akka |
|
| UdpListener | | Class | akka.io | Akka |
|
| UdpManager | UdpManager is a facade for simple fire-and-forget style UDP operations UdpManager is obtainable by calling IO(Udp) (see IO and Udp) | Class | akka.io | Akka |
|
| UdpMessage | Java API: factory methods for the message types used when communicating with the Udp service. | Class | akka.io | Akka |
|
| UdpMessage$ | Java API: factory methods for the message types used when communicating with the Udp service. | Class | akka.io | Akka |
|
| UdpSender | | Class | akka.io | Akka |
|
| UdpServerHandler | | Class | akka.remote.transport.netty | Akka |
|
| UdpSO | | Class | akka.io | Akka |
|
| UdpSO$ | | Class | akka.io | Akka |
|
| UnboundedControlAwareMailbox | UnboundedControlAwareMailbox is an unbounded MailboxType, that maintains two queues to allow messages that extend ControlMessage to be delivered with priority. | Class | akka.dispatch | Akka |
|
| UnboundedControlAwareMailbox$ | | Class | akka.dispatch | Akka |
|
| UnboundedControlAwareMessageQueueSemantics | | Interface | akka.dispatch | Akka |
|
| UnboundedDequeBasedMailbox | UnboundedDequeBasedMailbox is an unbounded MailboxType, backed by a Deque. | Class | akka.dispatch | Akka |
|
| UnboundedDequeBasedMailbox$ | | Class | akka.dispatch | Akka |
|
| UnboundedDequeBasedMessageQueue | UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i. | Interface | akka.dispatch | Akka |
|
| UnboundedMailbox | UnboundedMailbox is the default unbounded MailboxType used by Akka Actors. | Class | akka.dispatch | Akka |
|
| UnboundedMailbox$ | | Class | akka.dispatch | Akka |
|
| UnboundedPriorityMailbox | UnboundedPriorityMailbox is an unbounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
| UnboundedPriorityMailbox$ | | Class | akka.dispatch | Akka |
|
| UnboundedQueueBasedMessageQueue | Try to dequeue the next message from this queue, return null failing that. | Interface | akka.dispatch | Akka |
|
| UnboundedStablePriorityMailbox | UnboundedStablePriorityMailbox is an unbounded mailbox that allows for prioritization of its contents. | Class | akka.dispatch | Akka |
|
| UnboundedStablePriorityMailbox$ | | Class | akka.dispatch | Akka |
|
| UnboundedStash | The UnboundedStash trait is a version of Stash that enforces an unbounded stash for you actor. | Interface | akka.actor | Akka |
|
| UndefinedUidActorRef | | Class | akka.actor.dungeon | Akka |
|
| UnhandledMessage | This message is published to the EventStream whenever an Actor receives a message it doesn't understandSee Also:Serialized Form | Class | akka.actor | Akka |
|
| UnhandledMessage$ | | Class | akka.actor | Akka |
|
| UninitializedMessageException | Thrown when attempting to build a protocol message that is missing required fields. | Class | akka.protobuf | Akka |
|
| UniqueAddress | Member identifier consisting of address and random uid. | Class | akka.cluster | Akka |
|
| UniqueAddress$ | | Class | akka.cluster | Akka |
|
| UnitCaseStatement | | Class | akka.japi.pf | Akka |
|
| UnitMatch | Version of PartialFunction that can be built during This is a specialized version of UnitMatch to map java | Class | akka.japi.pf | Akka |
|
| UnitPFBuilder | A builder for PartialFunction. | Class | akka.japi.pf | Akka |
|
| UnknownFieldSet | UnknownFieldSet is used to keep track of fields which were seen when parsing a protocol message but whose field numbers or types are unrecognized. | Class | akka.protobuf | Akka |
|
| UnmodifiableLazyStringList | An implementation of LazyStringList that wraps another LazyStringList such that it cannot be modified via the wrapper. | Class | akka.protobuf | Akka |
|
| UnregisteringLogService | Message sent when LogService is unregistered. | Class | akka.osgi | Akka |
|
| UnregisteringLogService$ | Message sent when LogService is unregistered. | Class | akka.osgi | Akka |
|
| UnrestrictedStash | A version of Stash that does not enforce any mailbox type. | Interface | akka.actor | Akka |
|
| Unsafe | | Class | akka.util | Akka |
|
| UnstartedCell | | Class | akka.actor | Akka |
|
| UntypedActor | Actor base trait that should be extended by or mixed to create an Actor with the semantics of the 'Actor Model': http://en. | Class | akka.actor | Akka |
|
| UntypedActorContext | UntypedActorContext is the UntypedActor equivalent of ActorContext, containing the Java API | Interface | akka.actor | Akka |
|
| UntypedActorWithStash | Actor base class that should be extended to create an actor with a stash. | Class | akka.actor | Akka |
|
| UntypedActorWithUnboundedStash | Actor base class with Stash that enforces an unbounded deque for the actor. | Class | akka.actor | Akka |
|
| UntypedActorWithUnrestrictedStash | Actor base class with Stash that does not enforce any mailbox type. | Class | akka.actor | Akka |
|
| UntypedConsumerActor | Subclass this abstract class to create an MDB-style untyped consumer actor. | Class | akka.camel.javaapi | Akka |
|
| UntypedPersistentActor | Java API: an persistent actor - can be used to implement command or event sourcing. | Class | akka.persistence | Akka |
|
| UntypedPersistentActorWithAtLeastOnceDelivery | Java API: Use this class instead of UntypedPersistentActor to send messages with at-least-once delivery semantics to destinations. | Class | akka.persistence | Akka |
|
| UntypedPersistentView | | Class | akka.persistence | Akka |
|
| UntypedProducerActor | Subclass this abstract class to create an untyped producer actor. | Class | akka.camel.javaapi | Akka |
|
| Unwatch | | Class | akka.dispatch.sysmsg | Akka |
|
| Unwatch$ | | Class | akka.dispatch.sysmsg | Akka |
|
| Update | Instructs a PersistentView to update itself. | Class | akka.persistence | Akka |
|
| Update$ | | Class | akka.persistence | Akka |
|
| Util | | Class | akka.japi | Akka |
|
| Util$ | | Class | akka.japi | Akka |
|
| VectorClock | | Class | akka.cluster | Akka |
|
| VectorClock$ | VectorClock module with helper classes and methods. | Class | akka.cluster | Akka |
|
| VectorClockStats | | Class | akka.cluster | Akka |
|
| VectorClockStats$ | | Class | akka.cluster | Akka |
|
| VersionVector | Representation of a Vector-based clock (counting clock), inspired by Lamport logical clocks. | Class | akka.cluster.ddata | Akka |
|
| VersionVector$ | VersionVector module with helper classes and methods. | Class | akka.cluster.ddata | Akka |
|
| VirtualPathContainer | Internal implementation detail used for paths like “/temp”See Also:Serialized Form | Class | akka.actor | Akka |
|
| WarningFilter | Filter which matches Warning events, if they satisfy the given criteria: source, if given, applies a filter on the event’s originmessage applies a filter on the event’s message (either with String. | Class | akka.testkit | Akka |
|
| WarningFilter$ | | Class | akka.testkit | Akka |
|
| Watch | | Class | akka.dispatch.sysmsg | Akka |
|
| Watch$ | | Class | akka.dispatch.sysmsg | Akka |
|
| WeightedRoutees | Pick routee based on its weight. | Class | akka.cluster.metrics | Akka |
|
| WeightedRoutees | Pick routee based on its weight. | Class | akka.cluster.routing | Akka |
|
| WildcardTree | | Class | akka.util | Akka |
|
| WildcardTree$ | | Class | akka.util | Akka |
|
| WireFormat | This class is used internally by the Protocol Buffer library and generated message implementations. | Class | akka.protobuf | Akka |
|
| WireFormats | | Class | akka.remote | Akka |
|
| WithListeners | | Class | akka.routing | Akka |
|
| WithListeners$ | | Class | akka.routing | Akka |
|
| WithUdpSend | | Interface | akka.io | Akka |
|
| WorkList | Fast, small, and dirty implementation of a linked list that removes transient work entries once they are processed. | Class | akka.contrib.pattern | Akka |
|
| WorkList$ | Provides the utility methods and constructors to the WorkList class. | Class | akka.contrib.pattern | Akka |
|
| WriteAggregator | | Class | akka.cluster.ddata | Akka |
|
| WriteAggregator$ | | Class | akka.cluster.ddata | Akka |
|
| WriteEventAdapter | Facility to convert to specialised data models, as may be required by specialized persistence Journals. | Interface | akka.persistence.journal | Akka |
|
| WriteJournalBase | | Interface | akka.persistence.journal | Akka |