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 |