|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
IOManager
to accept an incoming
connection to the ServerSocketChannel associated with this
IO.Handle
.
Actor
.
Actor
.
Actor
.
Actor
.
IOManagerActor
that performs the actual
IO.
ActorClassification
An EventBus where the Subscribers are ActorRefs and the Classifier is ActorRef
Means that ActorRefs "listen" to other ActorRefs
E is the Event typeActorSystem
.
".."
- actorFor(Iterable<String>) -
Method in interface akka.actor.ActorRefFactory
- Java API: Look-up an actor by applying the given path elements, starting from the
current context, where
".."
- actorFor(ActorPath) -
Method in interface akka.actor.ActorRefProvider
- Create actor reference for a specified local or remote path.
- actorFor(InternalActorRef, String) -
Method in interface akka.actor.ActorRefProvider
- Create actor reference for a specified local or remote path, which will
be parsed using java.net.URI.
- actorFor(InternalActorRef, Iterable<String>) -
Method in interface akka.actor.ActorRefProvider
- Create actor reference for the specified child path starting at the
given starting point.
- actorFor(InternalActorRef, String) -
Method in class akka.actor.LocalActorRefProvider
-
- actorFor(ActorPath) -
Method in class akka.actor.LocalActorRefProvider
-
- actorFor(InternalActorRef, Iterable<String>) -
Method in class akka.actor.LocalActorRefProvider
-
- actorFor(ActorPath) -
Method in class akka.remote.RemoteActorRefProvider
-
- actorFor(akka.actor.InternalActorRef, String) -
Method in class akka.remote.RemoteActorRefProvider
-
- actorFor(akka.actor.InternalActorRef, Iterable<String>) -
Method in class akka.remote.RemoteActorRefProvider
-
- ActorInitializationException - Exception in akka.actor
- An ActorInitializationException is thrown when the the initialization logic for an Actor fails.
- ActorInitializationException(ActorRef, String, Throwable) -
Constructor for exception akka.actor.ActorInitializationException
-
- ActorInitializationException$ - Class in akka.actor
-
- ActorInitializationException$() -
Constructor for class akka.actor.ActorInitializationException$
-
- ActorInterruptedException - Exception in akka.actor
- 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.
- ActorKilledException - Exception in akka.actor
- ActorKilledException is thrown when an Actor receives the akka.actor.Kill message
- ActorKilledException$ - Class in akka.actor
-
- ActorKilledException$() -
Constructor for class akka.actor.ActorKilledException$
-
- ActorLogging - Interface in akka.actor
- Mix in ActorLogging into your Actor to easily obtain a reference to a logger, which is available under the name "log".
- ActorNotRegisteredException - Exception in akka.camel
- Thrown to indicate that the actor referenced by an endpoint URI cannot be
found in the actor system.
- ActorNotRegisteredException(String) -
Constructor for exception akka.camel.ActorNotRegisteredException
-
- actorOf(Props) -
Method in interface akka.actor.ActorRefFactory
- Create new actor as child of this context and give it an automatically
generated name (currently similar to base64-encoded integer count,
reversed and with “$” prepended, may change in the future).
- actorOf(Props, String) -
Method in interface akka.actor.ActorRefFactory
- Create new actor as child of this context with the given name, which must
not be null, empty or start with “$”.
- actorOf(ActorSystemImpl, Props, InternalActorRef, ActorPath, boolean, Option<Deploy>, boolean, boolean) -
Method in interface akka.actor.ActorRefProvider
- Actor factory with create-only semantics: will create an actor as
described by props with the given supervisor and path (may be different
in case of remote supervision).
- actorOf(ActorSystemImpl, Props, InternalActorRef, ActorPath, boolean, Option<Deploy>, boolean, boolean) -
Method in class akka.actor.LocalActorRefProvider
-
- actorOf(akka.actor.ActorSystemImpl, Props, akka.actor.InternalActorRef, ActorPath, boolean, Option<Deploy>, boolean, boolean) -
Method in class akka.remote.RemoteActorRefProvider
-
- ActorPath - Interface in akka.actor
- Actor path is a unique path to an actor that shows the creation path
up through the actor tree to the root actor.
- ActorPath$ - Class in akka.actor
-
- ActorPath$() -
Constructor for class akka.actor.ActorPath$
-
- ActorPathExtractor - Class in akka.actor
- Given an ActorPath it returns the Address and the path elements if the path is well-formed
- ActorPathExtractor() -
Constructor for class akka.actor.ActorPathExtractor
-
- ActorPathExtractor$ - Class in akka.actor
- Given an ActorPath it returns the Address and the path elements if the path is well-formed
- ActorPathExtractor$() -
Constructor for class akka.actor.ActorPathExtractor$
-
- actorProps() -
Method in class akka.actor.TypedProps
- Returns the akka.actor.Props representation of this TypedProps
- ActorRef - Class in akka.actor
- Immutable and serializable handle to an actor, which may or may not reside
on the local host or inside the same
ActorSystem
. - ActorRef() -
Constructor for class akka.actor.ActorRef
-
- actorRef() -
Method in class akka.actor.FSM.SubscribeTransitionCallBack
-
- actorRef() -
Method in class akka.actor.FSM.UnsubscribeTransitionCallBack
-
- actorRef() -
Method in class akka.pattern.AskSupport.AskableActorRef
-
- ActorRefFactory - Interface in akka.actor
- Interface implemented by ActorSystem and ActorContext, the only two places
from which you can get fresh actors.
- ActorRefProvider - Interface in akka.actor
- Interface for all ActorRef providers to implement.
- ActorRouteDefinition<T extends
> - Class in akka.camel- Wraps a
org.apache.camel.model.ProcessorDefinition
. - ActorRouteDefinition(<any>) -
Constructor for class akka.camel.ActorRouteDefinition
-
- actors() -
Static method in class akka.dispatch.MessageDispatcher
-
- actorSelection(String) -
Method in interface akka.actor.ActorRefFactory
- Construct an
ActorSelection
from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
- ActorSelection - Class in akka.actor
- An ActorSelection is a logical view of a section of an ActorSystem's tree of Actors,
allowing for broadcasting of messages to that section.
- ActorSelection() -
Constructor for class akka.actor.ActorSelection
-
- ActorSelection$ - Class in akka.actor
- An ActorSelection is a logical view of a section of an ActorSystem's tree of Actors,
allowing for broadcasting of messages to that section.
- ActorSelection$() -
Constructor for class akka.actor.ActorSelection$
-
- ActorSystem - Class in akka.actor
- An actor system is a hierarchical group of actors which share common
configuration, e.g. dispatchers, deployments, remote capabilities and
addresses.
- ActorSystem() -
Constructor for class akka.actor.ActorSystem
-
- ActorSystem$ - Class in akka.actor
-
- ActorSystem$() -
Constructor for class akka.actor.ActorSystem$
-
- ActorSystem.Settings - Class in akka.actor
- Settings are the overall ActorSystem Settings which also provides a convenient access to the Config object.
- ActorSystem.Settings(ClassLoader, com.typesafe.config.Config, String) -
Constructor for class akka.actor.ActorSystem.Settings
-
- ActorSystemActivator - Class in akka.osgi
- Abstract bundle activator implementation to bootstrap and configure an actor system in an
OSGi environment.
- ActorSystemActivator() -
Constructor for class akka.osgi.ActorSystemActivator
-
- actorSystemConfig(org.osgi.framework.BundleContext) -
Method in class akka.osgi.aries.blueprint.BlueprintActorSystemFactory
- Strategy method to create the Config for the ActorSystem, ensuring that the default/reference configuration is
loaded from the akka-actor bundle.
- actorSystemConfig(org.osgi.framework.BundleContext) -
Method in class akka.osgi.OsgiActorSystemFactory
- Strategy method to create the Config for the ActorSystem, ensuring that the default/reference configuration is
loaded from the akka-actor bundle.
- actorSystemName(Option<String>) -
Method in class akka.osgi.OsgiActorSystemFactory
- Determine the name for the
ActorSystem
Returns a default value of bundle--ActorSystem
is no name is being specified
- AdaptiveLoadBalancingRouter - Class in akka.cluster.routing
- A Router that performs load balancing of messages to cluster nodes based on
cluster metric data.
- AdaptiveLoadBalancingRouter(MetricsSelector, int, Iterable<String>, Option<Resizer>, String, SupervisorStrategy) -
Constructor for class akka.cluster.routing.AdaptiveLoadBalancingRouter
-
- AdaptiveLoadBalancingRouter(MetricsSelector, int) -
Constructor for class akka.cluster.routing.AdaptiveLoadBalancingRouter
- Java API: Constructor that sets nrOfInstances to be created.
- AdaptiveLoadBalancingRouter(MetricsSelector, Iterable<String>) -
Constructor for class akka.cluster.routing.AdaptiveLoadBalancingRouter
- Java API: Constructor that sets the routees to be used.
- AdaptiveLoadBalancingRouter(MetricsSelector, Resizer) -
Constructor for class akka.cluster.routing.AdaptiveLoadBalancingRouter
- Java API: Constructor that sets the resizer to be used.
- AdaptiveLoadBalancingRouter$ - Class in akka.cluster.routing
-
- AdaptiveLoadBalancingRouter$() -
Constructor for class akka.cluster.routing.AdaptiveLoadBalancingRouter$
-
- AdaptiveLoadBalancingRouterLike - Interface in akka.cluster.routing
- INTERNAL API.
- add(QItem) -
Method in class akka.actor.mailbox.filebased.filequeue.Journal
-
- add(byte[], long) -
Method in class akka.actor.mailbox.filebased.filequeue.PersistentQueue
- Add a value to the end of the queue, transactionally.
- add(byte[]) -
Method in class akka.actor.mailbox.filebased.filequeue.PersistentQueue
-
- add(String, byte[], int) -
Method in class akka.actor.mailbox.filebased.filequeue.QueueCollection
- Add an item to a named queue.
- add(String, byte[]) -
Method in class akka.actor.mailbox.filebased.filequeue.QueueCollection
-
- add(T) -
Method in class akka.routing.ConsistentHash
- Java API: Adds a node to the node ring.
- addAllMetadata(Iterable<? extends RemoteProtocol.MetadataEntryProtocol>) -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- addDowned(Address) -
Method in class akka.contrib.pattern.ClusterSingletonManager
-
- addFilter(EventFilter) -
Method in class akka.testkit.TestEventListener
-
- addLogger(akka.actor.ActorSystemImpl, Class<? extends Actor>, Logging.LogLevel, String) -
Method in interface akka.event.LoggingBus
- INTERNAL API
- AddLoggingReceive() -
Method in class akka.actor.ActorSystem.Settings
-
- addMetadata(RemoteProtocol.MetadataEntryProtocol) -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- addMetadata(int, RemoteProtocol.MetadataEntryProtocol) -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- addMetadata(RemoteProtocol.MetadataEntryProtocol.Builder) -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- addMetadata(int, RemoteProtocol.MetadataEntryProtocol.Builder) -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- addMetadataBuilder() -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- addMetadataBuilder(int) -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- addNameToBuffer(StringBuffer, String, String) -
Method in class akka.jmx.Client
-
- addRemoved(Address) -
Method in class akka.contrib.pattern.ClusterSingletonManager
-
- address() -
Method in interface akka.actor.ActorPath
- The Address under which this path can be reached; walks up the tree to
the RootActorPath.
- Address - Class in akka.actor
- The address specifies the physical location under which an Actor can be
reached.
- Address(String, String) -
Constructor for class akka.actor.Address
-
- Address(String, String, String, int) -
Constructor for class akka.actor.Address
-
- address() -
Method in class akka.actor.ChildActorPath
-
- address() -
Method in class akka.actor.IO.Connect
-
- address() -
Method in class akka.actor.IO.Connected
-
- address() -
Method in class akka.actor.IO.Listen
-
- address() -
Method in class akka.actor.IO.Listening
-
- address() -
Method in class akka.actor.RootActorPath
-
- address() -
Method in class akka.cluster.ClusterUserAction.Down
-
- address() -
Method in class akka.cluster.ClusterUserAction.Join
-
- address() -
Method in class akka.cluster.ClusterUserAction.Leave
-
- address() -
Method in class akka.cluster.Member
-
- address() -
Method in class akka.cluster.NodeMetrics
-
- address() -
Method in class akka.cluster.StandardMetrics.Cpu
-
- address() -
Method in class akka.cluster.StandardMetrics.HeapMemory
-
- address() -
Method in class akka.remote.RemoteTransport
- Address to be used in RootActorPath of refs generated for this transport.
- Address$ - Class in akka.actor
- Returns a String representation formatted as:
@:- Address$() -
Constructor for class akka.actor.Address$
-
- AddressFromURIString - Class in akka.actor
- This object serves as extractor for Scala and as address parser for Java.
- AddressFromURIString() -
Constructor for class akka.actor.AddressFromURIString
-
- AddressFromURIString$ - Class in akka.actor
- This object serves as extractor for Scala and as address parser for Java.
- AddressFromURIString$() -
Constructor for class akka.actor.AddressFromURIString$
-
- addressOrdering() -
Method in class akka.cluster.Member$
Address
ordering type class, sorts addresses by host and port.
- addressOrdering() -
Static method in class akka.cluster.Member
Address
ordering type class, sorts addresses by host and port.
- addressTerminated() -
Method in class akka.actor.Terminated
-
- addTime() -
Method in class akka.actor.mailbox.filebased.filequeue.QItem
-
- addToCache(Seq<Tuple2<Object, Set<Object>>>) -
Method in interface akka.event.SubchannelClassification
-
- advance() -
Method in interface akka.actor.LoggingFSM
-
- AES128CounterInetRNG - Class in akka.remote.security.provider
- Internal API
This class is a wrapper around the 128-bit AESCounterRNG algorithm provided by http://maths.uncommons.org/
It uses the default seed generator which uses one of the following 3 random seed sources:
Depending on availability: random.org, /dev/random, and SecureRandom (provided by Java)
The only method used by netty ssl is engineNextBytes(bytes)
- AES128CounterInetRNG() -
Constructor for class akka.remote.security.provider.AES128CounterInetRNG
-
- AES128CounterSecureRNG - Class in akka.remote.security.provider
- Internal API
This class is a wrapper around the 128-bit AESCounterRNG algorithm provided by http://maths.uncommons.org/
The only method used by netty ssl is engineNextBytes(bytes)
This RNG is good to use to prevent startup delay when you don't have Internet access to random.org
- AES128CounterSecureRNG() -
Constructor for class akka.remote.security.provider.AES128CounterSecureRNG
-
- AES256CounterInetRNG - Class in akka.remote.security.provider
- Internal API
This class is a wrapper around the 256-bit AESCounterRNG algorithm provided by http://maths.uncommons.org/
It uses the default seed generator which uses one of the following 3 random seed sources:
Depending on availability: random.org, /dev/random, and SecureRandom (provided by Java)
The only method used by netty ssl is engineNextBytes(bytes)
- AES256CounterInetRNG() -
Constructor for class akka.remote.security.provider.AES256CounterInetRNG
-
- AES256CounterSecureRNG - Class in akka.remote.security.provider
- Internal API
This class is a wrapper around the 256-bit AESCounterRNG algorithm provided by http://maths.uncommons.org/
The only method used by netty ssl is engineNextBytes(bytes)
This RNG is good to use to prevent startup delay when you don't have Internet access to random.org
- AES256CounterSecureRNG() -
Constructor for class akka.remote.security.provider.AES256CounterSecureRNG
-
- Affinity - Class in akka.zeromq
- The
Affinity
option shall set the I/O thread affinity for newly created connections on the specified socket. - Affinity(long) -
Constructor for class akka.zeromq.Affinity
-
- affinity() -
Method in class akka.zeromq.ZeroMQ$
- The message to ask a ZeroMQ socket for its affinity configuration.
- affinity() -
Static method in class akka.zeromq.ZeroMQ
- The message to ask a ZeroMQ socket for its affinity configuration.
- Affinity$ - Class in akka.zeromq
- Gets the
Affinity
value - Affinity$() -
Constructor for class akka.zeromq.Affinity$
-
- after(FiniteDuration, Scheduler, Function0<Future<T>>, ExecutionContext) -
Method in interface akka.pattern.FutureTimeoutSupport
- Returns a
Future
that will be completed with the success or failure of the provided value
after the specified duration.
- after(FiniteDuration, Scheduler, ExecutionContext, Callable<Future<T>>) -
Method in class akka.pattern.Patterns$
- Returns a
Future
that will be completed with the success or failure of the provided Callable
after the specified duration.
- after(FiniteDuration, Scheduler, ExecutionContext, Future<T>) -
Method in class akka.pattern.Patterns$
- Returns a
Future
that will be completed with the success or failure of the provided value
after the specified duration.
- after(FiniteDuration, Scheduler, ExecutionContext, Callable<Future<T>>) -
Static method in class akka.pattern.Patterns
- Returns a
Future
that will be completed with the success or failure of the provided Callable
after the specified duration.
- after(FiniteDuration, Scheduler, ExecutionContext, Future<T>) -
Static method in class akka.pattern.Patterns
- Returns a
Future
that will be completed with the success or failure of the provided value
after the specified duration.
- after() -
Method in interface akka.transactor.Transactor
- A Receive block that runs after the coordinated transaction.
- after(Object) -
Method in class akka.transactor.UntypedTransactor
- A Receive block that runs after the coordinated transaction.
- afterAll() -
Method in class akka.actor.mailbox.DurableMailboxSpec
-
- afterAll() -
Method in class akka.testkit.AkkaSpec
-
- Agent<T> - Class in akka.agent
- The Agent class was inspired by agents in Clojure.
- Agent(T, ActorRefFactory, ActorSystem) -
Constructor for class akka.agent.Agent
-
- Agent(T, ActorSystem) -
Constructor for class akka.agent.Agent
-
- Agent$ - Class in akka.agent
- Factory method for creating an Agent.
- Agent$() -
Constructor for class akka.agent.Agent$
-
- akka - package akka
-
- akka.actor - package akka.actor
-
- akka.actor.dsl - package akka.actor.dsl
-
- akka.actor.mailbox - package akka.actor.mailbox
-
- akka.actor.mailbox.filebased - package akka.actor.mailbox.filebased
-
- akka.actor.mailbox.filebased.filequeue - package akka.actor.mailbox.filebased.filequeue
-
- akka.actor.mailbox.filebased.filequeue.tools - package akka.actor.mailbox.filebased.filequeue.tools
-
- akka.agent - package akka.agent
-
- akka.camel - package akka.camel
-
- akka.camel.internal.component - package akka.camel.internal.component
-
- akka.camel.javaapi - package akka.camel.javaapi
-
- akka.cluster - package akka.cluster
-
- akka.cluster.routing - package akka.cluster.routing
-
- akka.contrib.jul - package akka.contrib.jul
-
- akka.contrib.mailbox - package akka.contrib.mailbox
-
- akka.contrib.pattern - package akka.contrib.pattern
-
- akka.contrib.throttle - package akka.contrib.throttle
-
- akka.dispatch - package akka.dispatch
-
- akka.event - package akka.event
-
- akka.event.japi - package akka.event.japi
-
- akka.event.slf4j - package akka.event.slf4j
-
- akka.japi - package akka.japi
-
- akka.jmx - package akka.jmx
-
- akka.kernel - package akka.kernel
-
- akka.osgi - package akka.osgi
-
- akka.osgi.aries.blueprint - package akka.osgi.aries.blueprint
-
- akka.osgi.impl - package akka.osgi.impl
-
- akka.pattern - package akka.pattern
-
- akka.remote - package akka.remote
-
- akka.remote.routing - package akka.remote.routing
-
- akka.remote.security.provider - package akka.remote.security.provider
-
- akka.remote.serialization - package akka.remote.serialization
-
- akka.routing - package akka.routing
-
- akka.serialization - package akka.serialization
-
- akka.testkit - package akka.testkit
-
- akka.transactor - package akka.transactor
-
- akka.util - package akka.util
-
- akka.util.internal - package akka.util.internal
-
- akka.zeromq - package akka.zeromq
-
- akkaActorClassLoader() -
Method in class akka.osgi.OsgiActorSystemFactory$
- Class loader of akka-actor bundle.
- akkaActorClassLoader() -
Static method in class akka.osgi.OsgiActorSystemFactory
- Class loader of akka-actor bundle.
- AkkaCamelException - Exception in akka.camel
- An exception indicating that the exchange to the camel endpoint failed.
- AkkaCamelException(Throwable) -
Constructor for exception akka.camel.AkkaCamelException
-
- AkkaException - Exception in akka
- Akka base Exception.
- AkkaException(String, Throwable) -
Constructor for exception akka.AkkaException
-
- AkkaException(String) -
Constructor for exception akka.AkkaException
-
- AkkaProvider - Class in akka.remote.security.provider
- A provider that for AES128CounterRNGFast, a cryptographically secure random number generator through SecureRandom
- AkkaProvider() -
Constructor for class akka.remote.security.provider.AkkaProvider
-
- AkkaProvider$ - Class in akka.remote.security.provider
- A provider that for AES128CounterRNGFast, a cryptographically secure random number generator through SecureRandom
- AkkaProvider$() -
Constructor for class akka.remote.security.provider.AkkaProvider$
-
- AkkaSpec - Class in akka.testkit
-
- AkkaSpec(ActorSystem) -
Constructor for class akka.testkit.AkkaSpec
-
- AkkaSpec(com.typesafe.config.Config) -
Constructor for class akka.testkit.AkkaSpec
-
- AkkaSpec() -
Constructor for class akka.testkit.AkkaSpec
-
- AkkaSpec$ - Class in akka.testkit
-
- AkkaSpec$() -
Constructor for class akka.testkit.AkkaSpec$
-
- AkkaSpecSpec - Class in akka.testkit
-
- AkkaSpecSpec() -
Constructor for class akka.testkit.AkkaSpecSpec
-
- all() -
Method in class akka.zeromq.Subscribe$
-
- all() -
Static method in class akka.zeromq.Subscribe
-
- AllForOneStrategy - Class in akka.actor
- Applies the fault handling
Directive
(Resume, Restart, Stop) specified in the Decider
to all children when one fails, as opposed to OneForOneStrategy
that applies
it only to the child actor that failed. - AllForOneStrategy(int, Duration, PartialFunction<Throwable, SupervisorStrategy.Directive>) -
Constructor for class akka.actor.AllForOneStrategy
-
- AllForOneStrategy(int, Duration, Function<Throwable, SupervisorStrategy.Directive>) -
Constructor for class akka.actor.AllForOneStrategy
-
- AllForOneStrategy(int, Duration, Iterable<Class<? extends Throwable>>) -
Constructor for class akka.actor.AllForOneStrategy
-
- AllForOneStrategy(int, Duration, Class<?>[]) -
Constructor for class akka.actor.AllForOneStrategy
-
- AllForOneStrategy() -
Method in interface akka.actor.dsl.Creators.Act
-
- AllForOneStrategy$ - Class in akka.actor
-
- AllForOneStrategy$() -
Constructor for class akka.actor.AllForOneStrategy$
-
- AllLogLevels() -
Method in class akka.event.Logging$
-
- AllLogLevels() -
Static method in class akka.event.Logging
-
- allowCorePoolTimeout() -
Method in class akka.dispatch.ThreadPoolConfig
-
- allowLocalRoutees() -
Method in class akka.cluster.routing.ClusterRouterSettings
-
- alone() -
Method in interface akka.transactor.Transactor
- Default coordination - no other transactors.
- alpha(FiniteDuration, FiniteDuration) -
Method in class akka.cluster.EWMA$
- Calculate the alpha (decay factor) used in
EWMA
from specified half-life and interval between observations.
- alter(Function1<T, T>, Timeout) -
Method in class akka.agent.Agent
- Dispatch a function to update the internal state, and return a Future where
that new state can be obtained within the given timeout.
- alter(Function<T, T>, FiniteDuration) -
Method in class akka.agent.Agent
- Java API
Dispatch a function to update the internal state, and return a Future where that new state can be obtained
within the given timeout
- alterOff(Function1<T, T>, Timeout, ExecutionContext) -
Method in class akka.agent.Agent
- Dispatch a function to update the internal state but on its own thread,
and return a Future where that new state can be obtained within the given timeout.
- alterOff(Function<T, T>, FiniteDuration, ExecutionContext) -
Method in class akka.agent.Agent
- Java API:
Dispatch a function to update the internal state but on its own thread,
and return a Future where that new state can be obtained within the given timeout.
- ap() -
Method in class akka.testkit.TestActor.SetAutoPilot
-
- apply(Object) -
Method in class akka.actor.Actor.emptyBehavior$
-
- apply(ActorRef, String) -
Method in class akka.actor.ActorSelection$
- Construct an ActorSelection from the given string representing a path
relative to the given target.
- apply(ActorRef, String) -
Static method in class akka.actor.ActorSelection
- Construct an ActorSelection from the given string representing a path
relative to the given target.
- apply() -
Method in class akka.actor.ActorSystem$
- Creates a new ActorSystem with the name "default",
obtains the current ClassLoader by first inspecting the current threads' getContextClassLoader,
then tries to walk the stack to find the callers class loader, then falls back to the ClassLoader
associated with the ActorSystem class.
- apply(String) -
Method in class akka.actor.ActorSystem$
- Creates a new ActorSystem with the specified name,
obtains the current ClassLoader by first inspecting the current threads' getContextClassLoader,
then tries to walk the stack to find the callers class loader, then falls back to the ClassLoader
associated with the ActorSystem class.
- apply(String, com.typesafe.config.Config) -
Method in class akka.actor.ActorSystem$
- Creates a new ActorSystem with the name "default", and the specified Config, then
obtains the current ClassLoader by first inspecting the current threads' getContextClassLoader,
then tries to walk the stack to find the callers class loader, then falls back to the ClassLoader
associated with the ActorSystem class.
- apply(String, com.typesafe.config.Config, ClassLoader) -
Method in class akka.actor.ActorSystem$
- Creates a new ActorSystem with the name "default", the specified Config, and specified ClassLoader
- apply() -
Static method in class akka.actor.ActorSystem
- Creates a new ActorSystem with the name "default",
obtains the current ClassLoader by first inspecting the current threads' getContextClassLoader,
then tries to walk the stack to find the callers class loader, then falls back to the ClassLoader
associated with the ActorSystem class.
- apply(String) -
Static method in class akka.actor.ActorSystem
- Creates a new ActorSystem with the specified name,
obtains the current ClassLoader by first inspecting the current threads' getContextClassLoader,
then tries to walk the stack to find the callers class loader, then falls back to the ClassLoader
associated with the ActorSystem class.
- apply(String, com.typesafe.config.Config) -
Static method in class akka.actor.ActorSystem
- Creates a new ActorSystem with the name "default", and the specified Config, then
obtains the current ClassLoader by first inspecting the current threads' getContextClassLoader,
then tries to walk the stack to find the callers class loader, then falls back to the ClassLoader
associated with the ActorSystem class.
- apply(String, com.typesafe.config.Config, ClassLoader) -
Static method in class akka.actor.ActorSystem
- Creates a new ActorSystem with the name "default", the specified Config, and specified ClassLoader
- apply(String, String) -
Method in class akka.actor.Address$
- Constructs a new Address with the specified protocol and system name
- apply(String, String, String, int) -
Method in class akka.actor.Address$
- Constructs a new Address with the specified protocol, system name, host and port
- apply(String, String) -
Static method in class akka.actor.Address
- Constructs a new Address with the specified protocol and system name
- apply(String, String, String, int) -
Static method in class akka.actor.Address
- Constructs a new Address with the specified protocol, system name, host and port
- apply(String) -
Method in class akka.actor.AddressFromURIString$
- Try to construct an Address from the given String or throw a java.net.MalformedURLException.
- apply(String) -
Static method in class akka.actor.AddressFromURIString
- Try to construct an Address from the given String or throw a java.net.MalformedURLException.
- apply(ActorSystem) -
Method in interface akka.actor.ExtensionId
- Returns an instance of the extension identified by this ExtensionId instance.
- apply(Object) -
Method in class akka.actor.FSM.NullFunction$
-
- apply(A) -
Method in class akka.actor.IO.Iteratee$
- Wrap the provided value within a
IO.Done
IO.Iteratee
.
- apply() -
Method in class akka.actor.IO.Iteratee$
- Returns Iteratee.unit
- apply(IO.Input) -
Method in class akka.actor.IO.Iteratee
- Processes the given
IO.Input
, returning the resulting
Iteratee and the remaining Input.
- apply(IO.Input) -
Method in interface akka.actor.IO.IterateeRef
-
- apply(Function0<IO.IterateeRef<V>>) -
Method in class akka.actor.IO.IterateeRef.Map$
- Uses a factory to create the initial IterateeRef for each new key.
- apply(IO.Input) -
Method in class akka.actor.IO.IterateeRefAsync
-
- apply(IO.Input) -
Method in class akka.actor.IO.IterateeRefSync
-
- apply() -
Method in class akka.actor.mailbox.filebased.filequeue.Counter
-
- apply() -
Method in class akka.actor.mailbox.filebased.filequeue.OverlaySetting
-
- apply() -
Method in class akka.actor.mailbox.filebased.filequeue.tools.QueueDumper
-
- apply(ClassTag<T>) -
Method in class akka.actor.Props$
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
of the supplied type using the default constructor.
- apply(Class<? extends Actor>) -
Method in class akka.actor.Props$
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
of the supplied class using the default constructor.
- apply(Function0<Actor>) -
Method in class akka.actor.Props$
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
using the supplied thunk.
- apply(Creator<? extends Actor>) -
Method in class akka.actor.Props$
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
using the supplied thunk.
- apply(ClassTag<T>) -
Static method in class akka.actor.Props
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
of the supplied type using the default constructor.
- apply(Class<? extends Actor>) -
Static method in class akka.actor.Props
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
of the supplied class using the default constructor.
- apply(Function0<Actor>) -
Static method in class akka.actor.Props
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
using the supplied thunk.
- apply(Creator<? extends Actor>) -
Static method in class akka.actor.Props
- Returns a Props that has default values except for "creator" which will be a function that creates an instance
using the supplied thunk.
- apply(ActorContext) -
Method in class akka.actor.TypedActor$
- Returns a contextual TypedActorFactory of this extension, this means that any TypedActors created by this TypedActorExtension
will be children to the specified context, this allows for creating hierarchies of TypedActors.
- apply(ActorContext) -
Static method in class akka.actor.TypedActor
- Returns a contextual TypedActorFactory of this extension, this means that any TypedActors created by this TypedActorExtension
will be children to the specified context, this allows for creating hierarchies of TypedActors.
- apply(Object) -
Method in class akka.actor.TypedActor.MethodCall
- Invokes the Method on the supplied instance
- apply(Class<T>) -
Method in class akka.actor.TypedProps$
- Uses the supplied class as the factory for the TypedActor implementation,
proxying all the interfaces it implements.
- apply(Class<? super T>, Class<T>) -
Method in class akka.actor.TypedProps$
- Uses the supplied class as the factory for the TypedActor implementation,
and that has the specified interface,
or if the interface class is not an interface, all the interfaces it implements,
appended in the sequence of interfaces.
- apply(Class<? super T>, Function0<T>) -
Method in class akka.actor.TypedProps$
- Uses the supplied thunk as the factory for the TypedActor implementation,
and that has the specified interface,
or if the interface class is not an interface, all the interfaces it implements,
appended in the sequence of interfaces.
- apply(ClassTag<T>) -
Method in class akka.actor.TypedProps$
- Uses the supplied class as the factory for the TypedActor implementation,
proxying all the interfaces it implements.
- apply(Class<T>) -
Static method in class akka.actor.TypedProps
- Uses the supplied class as the factory for the TypedActor implementation,
proxying all the interfaces it implements.
- apply(Class<? super T>, Class<T>) -
Static method in class akka.actor.TypedProps
- Uses the supplied class as the factory for the TypedActor implementation,
and that has the specified interface,
or if the interface class is not an interface, all the interfaces it implements,
appended in the sequence of interfaces.
- apply(Class<? super T>, Function0<T>) -
Static method in class akka.actor.TypedProps
- Uses the supplied thunk as the factory for the TypedActor implementation,
and that has the specified interface,
or if the interface class is not an interface, all the interfaces it implements,
appended in the sequence of interfaces.
- apply(ClassTag<T>) -
Static method in class akka.actor.TypedProps
- Uses the supplied class as the factory for the TypedActor implementation,
proxying all the interfaces it implements.
- apply(T, ActorSystem) -
Method in class akka.agent.Agent$
-
- apply() -
Method in class akka.agent.Agent
- Read the internal state of the agent.
- apply(Address, MemberStatus) -
Method in class akka.cluster.Member$
-
- apply(Address, MemberStatus) -
Static method in class akka.cluster.Member
-
- apply(int, int, boolean) -
Method in class akka.cluster.routing.ClusterRouterSettings$
- Settings for create and deploy of the routees
- apply(int, int) -
Method in class akka.cluster.routing.ClusterRouterSettings$
- Settings for remote deployment of the routees, allowed to use routees on own node
- apply(int, String, boolean) -
Method in class akka.cluster.routing.ClusterRouterSettings$
- Settings for lookup of the routees
- apply(int, String) -
Method in class akka.cluster.routing.ClusterRouterSettings$
- Settings for lookup of the routees, allowed to use routees on own node
- apply(int, int, boolean) -
Static method in class akka.cluster.routing.ClusterRouterSettings
- Settings for create and deploy of the routees
- apply(int, int) -
Static method in class akka.cluster.routing.ClusterRouterSettings
- Settings for remote deployment of the routees, allowed to use routees on own node
- apply(int, String, boolean) -
Static method in class akka.cluster.routing.ClusterRouterSettings
- Settings for lookup of the routees
- apply(int, String) -
Static method in class akka.cluster.routing.ClusterRouterSettings
- Settings for lookup of the routees, allowed to use routees on own node
- apply(String) -
Method in class akka.cluster.VectorClock.Node$
-
- apply() -
Method in class akka.cluster.VectorClock.Timestamp$
-
- apply(Object, ActorRef, ActorSystem) -
Method in class akka.dispatch.Envelope$
-
- apply(Object, ActorRef, ActorSystem) -
Static method in class akka.dispatch.Envelope
-
- apply(T) -
Method in class akka.dispatch.japi.BooleanFunctionBridge
-
- apply(T) -
Method in class akka.dispatch.japi.CallbackBridge
-
- apply(Throwable) -
Method in class akka.dispatch.japi.RecoverBridge
-
- apply(T) -
Method in class akka.dispatch.japi.UnitFunctionBridge
-
- apply(T) -
Method in class akka.dispatch.Mapper
- Override this method to perform the map operation, by default delegates to "checkedApply"
which by default throws an UnsupportedOperationException.
- apply(Function1<Object, Object>) -
Method in class akka.dispatch.PriorityGenerator$
- Creates a PriorityGenerator that uses the supplied function as priority generator
- apply(Function1<Object, Object>) -
Static method in class akka.dispatch.PriorityGenerator
- Creates a PriorityGenerator that uses the supplied function as priority generator
- apply(ActorSystem, T, LogSource<T>) -
Method in class akka.event.Logging$
- Obtain LoggingAdapter for the given actor system and source object.
- apply(LoggingBus, T, LogSource<T>) -
Method in class akka.event.Logging$
- Obtain LoggingAdapter for the given logging bus and source object.
- apply(ActorSystem, T, LogSource<T>) -
Static method in class akka.event.Logging
- Obtain LoggingAdapter for the given actor system and source object.
- apply(LoggingBus, T, LogSource<T>) -
Static method in class akka.event.Logging
- Obtain LoggingAdapter for the given logging bus and source object.
- apply(String, Class<?>, Object) -
Method in class akka.event.Logging.Error$
-
- apply(PartialFunction<Object, BoxedUnit>, ActorContext) -
Method in class akka.event.LoggingReceive$
- Wrap a Receive partial function in a logging enclosure, which sends a
debug message to the event bus each time before a message is matched.
- apply(Object) -
Method in class akka.event.LoggingReceive
-
- apply(T, LogSource<T>) -
Method in class akka.event.LogSource$
- Convenience converter access: given an implicit
LogSource
, generate the
string representation and originating class.
- apply(T, ActorSystem, LogSource<T>) -
Method in class akka.event.LogSource$
- Convenience converter access: given an implicit
LogSource
and
ActorSystem
, generate the string representation and
originating class.
- apply(T, LogSource<T>) -
Method in interface akka.event.LogSource
- Convenience converter access: given an implicit
LogSource
, generate the
string representation and originating class.
- apply(T, ActorSystem, LogSource<T>) -
Method in interface akka.event.LogSource
- Convenience converter access: given an implicit
LogSource
and
ActorSystem
, generate the string representation and
originating class.
- apply(String) -
Method in class akka.event.slf4j.Logger$
-
- apply(Class<?>, String) -
Method in class akka.event.slf4j.Logger$
-
- apply(String) -
Static method in class akka.event.slf4j.Logger
-
- apply(Class<?>, String) -
Static method in class akka.event.slf4j.Logger
-
- apply() -
Method in interface akka.japi.Effect
-
- apply(T) -
Method in interface akka.japi.Function
-
- apply(T1, T2) -
Method in interface akka.japi.Function2
-
- apply(A, boolean) -
Method in class akka.japi.JavaPartialFunction
-
- apply(A) -
Method in class akka.japi.JavaPartialFunction
-
- apply(T) -
Method in interface akka.japi.Procedure
-
- apply(org.osgi.framework.BundleContext) -
Method in class akka.osgi.impl.BundleDelegatingClassLoader$
-
- apply(org.osgi.framework.BundleContext) -
Static method in class akka.osgi.impl.BundleDelegatingClassLoader
-
- apply(org.osgi.framework.BundleContext) -
Method in class akka.osgi.OsgiActorSystemFactory$
-
- apply(org.osgi.framework.BundleContext) -
Static method in class akka.osgi.OsgiActorSystemFactory
-
- apply(Scheduler, int, FiniteDuration, FiniteDuration) -
Method in class akka.pattern.CircuitBreaker$
- Create a new CircuitBreaker.
- apply(Scheduler, int, FiniteDuration, FiniteDuration) -
Static method in class akka.pattern.CircuitBreaker
- Create a new CircuitBreaker.
- apply(Iterable<ActorRef>) -
Method in class akka.routing.BroadcastRouter$
- Creates a new BroadcastRouter, routing to the specified routees
- apply(Iterable<ActorRef>) -
Static method in class akka.routing.BroadcastRouter
- Creates a new BroadcastRouter, routing to the specified routees
- apply(Iterable<T>, int, ClassTag<T>) -
Method in class akka.routing.ConsistentHash$
-
- apply(Iterable<T>, int, ClassTag<T>) -
Static method in class akka.routing.ConsistentHash
-
- apply(Iterable<ActorRef>) -
Method in class akka.routing.ConsistentHashingRouter$
- Creates a new ConsistentHashingRouter, routing to the specified routees
- apply(Iterable<ActorRef>) -
Static method in class akka.routing.ConsistentHashingRouter
- Creates a new ConsistentHashingRouter, routing to the specified routees
- apply(Object) -
Method in class akka.routing.ConsistentHashingRouter.emptyConsistentHashMapping$
-
- apply(com.typesafe.config.Config) -
Method in class akka.routing.DefaultResizer$
- Creates a new DefaultResizer from the given configuration
- apply(com.typesafe.config.Config) -
Static method in class akka.routing.DefaultResizer
- Creates a new DefaultResizer from the given configuration
- apply(String) -
Method in class akka.routing.FromConfig$
-
- apply(String) -
Static method in class akka.routing.FromConfig
-
- apply(Iterable<ActorRef>) -
Method in class akka.routing.RandomRouter$
- Creates a new RandomRouter, routing to the specified routees
- apply(Iterable<ActorRef>) -
Static method in class akka.routing.RandomRouter
- Creates a new RandomRouter, routing to the specified routees
- apply(Iterable<ActorRef>) -
Method in class akka.routing.RoundRobinRouter$
- Creates a new RoundRobinRouter, routing to the specified routees
- apply(Iterable<ActorRef>) -
Static method in class akka.routing.RoundRobinRouter
- Creates a new RoundRobinRouter, routing to the specified routees
- apply(Iterable<ActorRef>, FiniteDuration) -
Method in class akka.routing.ScatterGatherFirstCompletedRouter$
- Creates a new ScatterGatherFirstCompletedRouter, routing to the specified routees, timing out after the specified Duration
- apply(Iterable<ActorRef>, FiniteDuration) -
Static method in class akka.routing.ScatterGatherFirstCompletedRouter
- Creates a new ScatterGatherFirstCompletedRouter, routing to the specified routees, timing out after the specified Duration
- apply(Iterable<ActorRef>) -
Method in class akka.routing.SmallestMailboxRouter$
- Creates a new SmallestMailboxRouter, routing to the specified routees
- apply(Iterable<ActorRef>) -
Static method in class akka.routing.SmallestMailboxRouter
- Creates a new SmallestMailboxRouter, routing to the specified routees
- apply(String, String, String, String, int, ClassTag<A>) -
Method in class akka.testkit.EventFilter$
- Create a filter for Error events.
- apply(Logging.LogEvent) -
Method in class akka.testkit.EventFilter
-
- apply(ActorRef) -
Method in class akka.testkit.ExtractRoute$
-
- apply(ActorRef) -
Static method in class akka.testkit.ExtractRoute
-
- apply(Function0<T>, ActorSystem) -
Method in class akka.testkit.TestActorRef$
-
- apply(Function0<T>, String, ActorSystem) -
Method in class akka.testkit.TestActorRef$
-
- apply(Props, ActorSystem) -
Method in class akka.testkit.TestActorRef$
-
- apply(Props, String, ActorSystem) -
Method in class akka.testkit.TestActorRef$
-
- apply(Props, ActorRef, String, ActorSystem) -
Method in class akka.testkit.TestActorRef$
-
- apply(ClassTag<T>, ActorSystem) -
Method in class akka.testkit.TestActorRef$
-
- apply(String, ClassTag<T>, ActorSystem) -
Method in class akka.testkit.TestActorRef$
-
- apply(Function0<T>, ActorSystem) -
Static method in class akka.testkit.TestActorRef
-
- apply(Function0<T>, String, ActorSystem) -
Static method in class akka.testkit.TestActorRef
-
- apply(Props, ActorSystem) -
Static method in class akka.testkit.TestActorRef
-
- apply(Props, String, ActorSystem) -
Static method in class akka.testkit.TestActorRef
-
- apply(Props, ActorRef, String, ActorSystem) -
Static method in class akka.testkit.TestActorRef
-
- apply(ClassTag<T>, ActorSystem) -
Static method in class akka.testkit.TestActorRef
-
- apply(String, ClassTag<T>, ActorSystem) -
Static method in class akka.testkit.TestActorRef
-
- apply(int) -
Method in class akka.testkit.TestBarrier$
-
- apply(int) -
Static method in class akka.testkit.TestBarrier
-
- apply(EventFilter, Seq<EventFilter>) -
Method in class akka.testkit.TestEvent.Mute$
-
- apply(EventFilter, Seq<EventFilter>) -
Method in class akka.testkit.TestEvent.UnMute$
-
- apply(Function0<T>, Predef.$less$colon$less<T, FSM<S, D>>, ActorSystem) -
Method in class akka.testkit.TestFSMRef$
-
- apply(Function0<T>, String, Predef.$less$colon$less<T, FSM<S, D>>, ActorSystem) -
Method in class akka.testkit.TestFSMRef$
-
- apply(Function0<T>, Predef.$less$colon$less<T, FSM<S, D>>, ActorSystem) -
Static method in class akka.testkit.TestFSMRef
-
- apply(Function0<T>, String, Predef.$less$colon$less<T, FSM<S, D>>, ActorSystem) -
Static method in class akka.testkit.TestFSMRef
-
- apply(int, ActorSystem) -
Method in class akka.testkit.TestLatch$
-
- apply(int, ActorSystem) -
Static method in class akka.testkit.TestLatch
-
- apply(ActorSystem) -
Method in class akka.testkit.TestProbe$
-
- apply(ActorSystem) -
Static method in class akka.testkit.TestProbe
-
- apply(Object, Timeout) -
Method in class akka.transactor.Coordinated$
- Creates a new Coordinated with the given message and Timeout
- apply(Object) -
Method in class akka.transactor.Coordinated
- Create a new Coordinated object and increment the number of members by one.
- apply(Class<?>) -
Method in class akka.util.BoxedType$
-
- apply(Class<?>) -
Static method in class akka.util.BoxedType
-
- apply(byte[]) -
Method in class akka.util.ByteIterator.ByteArrayIterator$
-
- apply(byte[], int, int) -
Method in class akka.util.ByteIterator.ByteArrayIterator$
-
- apply(LinearSeq<ByteIterator.ByteArrayIterator>) -
Method in class akka.util.ByteIterator.MultiByteArrayIterator$
-
- apply(byte[]) -
Method in class akka.util.ByteString$
- Creates a new ByteString by copying a byte array.
- apply(Seq<Object>) -
Method in class akka.util.ByteString$
- Creates a new ByteString by copying bytes.
- apply(Seq<T>, Integral<T>) -
Method in class akka.util.ByteString$
- Creates a new ByteString by converting from integral numbers to bytes.
- apply(ByteBuffer) -
Method in class akka.util.ByteString$
- Creates a new ByteString by copying bytes from a ByteBuffer.
- apply(String) -
Method in class akka.util.ByteString$
- Creates a new ByteString by encoding a String as UTF-8.
- apply(String, String) -
Method in class akka.util.ByteString$
- Creates a new ByteString by encoding a String with a charset.
- apply(int) -
Method in class akka.util.ByteString
-
- apply(int) -
Method in class akka.util.ByteString.ByteString1
-
- apply(int) -
Method in class akka.util.ByteString.ByteString1C
-
- apply(int) -
Method in class akka.util.ByteString.ByteStrings
-
- apply(byte[]) -
Method in class akka.util.CompactByteString$
- Creates a new CompactByteString by copying a byte array.
- apply(Seq<Object>) -
Method in class akka.util.CompactByteString$
- Creates a new CompactByteString by copying bytes.
- apply(Seq<T>, Integral<T>) -
Method in class akka.util.CompactByteString$
- Creates a new CompactByteString by converting from integral numbers to bytes.
- apply(ByteBuffer) -
Method in class akka.util.CompactByteString$
- Creates a new CompactByteString by copying bytes from a ByteBuffer.
- apply(String) -
Method in class akka.util.CompactByteString$
- Creates a new CompactByteString by encoding a String as UTF-8.
- apply(String, String) -
Method in class akka.util.CompactByteString$
- Creates a new CompactByteString by encoding a String with a charset.
- apply(byte[]) -
Static method in class akka.util.CompactByteString
- Creates a new CompactByteString by copying a byte array.
- apply(Seq<Object>) -
Static method in class akka.util.CompactByteString
- Creates a new CompactByteString by copying bytes.
- apply(Seq<T>, Integral<T>) -
Static method in class akka.util.CompactByteString
- Creates a new CompactByteString by converting from integral numbers to bytes.
- apply(ByteBuffer) -
Static method in class akka.util.CompactByteString
- Creates a new CompactByteString by copying bytes from a ByteBuffer.
- apply(String) -
Static method in class akka.util.CompactByteString
- Creates a new CompactByteString by encoding a String as UTF-8.
- apply(String, String) -
Static method in class akka.util.CompactByteString
- Creates a new CompactByteString by encoding a String with a charset.
- apply(long) -
Method in class akka.util.Timeout$
-
- apply(long, TimeUnit) -
Method in class akka.util.Timeout$
-
- apply(long) -
Static method in class akka.util.Timeout
-
- apply(long, TimeUnit) -
Static method in class akka.util.Timeout
-
- apply(int) -
Method in class akka.zeromq.Context$
-
- apply(int) -
Static method in class akka.zeromq.Context
-
- apply(Seq<Frame>) -
Method in interface akka.zeromq.Deserializer
-
- apply(String) -
Method in class akka.zeromq.Frame$
-
- apply(String) -
Static method in class akka.zeromq.Frame
-
- apply(String) -
Method in class akka.zeromq.Subscribe$
-
- apply(String) -
Static method in class akka.zeromq.Subscribe
-
- apply(String) -
Method in class akka.zeromq.Unsubscribe$
-
- apply(String) -
Static method in class akka.zeromq.Unsubscribe
-
- apply(byte[]) -
Method in class akka.zeromq.ZMQMessage$
-
- apply(com.google.protobuf.Message) -
Method in class akka.zeromq.ZMQMessage$
-
- apply(byte[]) -
Static method in class akka.zeromq.ZMQMessage
-
- apply(com.google.protobuf.Message) -
Static method in class akka.zeromq.ZMQMessage
-
- apply(Seq<Frame>) -
Method in class akka.zeromq.ZMQMessageDeserializer
-
- applyOrElse(A1, Function1<A1, B1>) -
Method in class akka.japi.JavaPartialFunction
-
- applyState(FSM.State<S, D>) -
Method in interface akka.actor.FSM
-
- ARRAY_OF_BYTE_ARRAY() -
Method in class akka.remote.serialization.ProtobufSerializer
-
- arrayBlockingQueue(int, boolean) -
Method in class akka.dispatch.ThreadPoolConfig$
-
- arrayBlockingQueue(int, boolean) -
Static method in class akka.dispatch.ThreadPoolConfig
-
- arrayHash(Object) -
Method in class akka.routing.MurmurHash$
- Compute a high-quality hash of an array
- arrayHash(Object) -
Static method in class akka.routing.MurmurHash
- Compute a high-quality hash of an array
- arrayToSeq(Object) -
Method in class akka.japi.Util$
- Turns an array into a Scala sequence.
- arrayToSeq(Class<?>[]) -
Method in class akka.japi.Util$
- Returns a Scala sequence representing the provided array of Classes,
an overloading of the generic arrayToSeq in Util, to accommodate for erasure.
- arrayToSeq(Object) -
Static method in class akka.japi.Util
- Turns an array into a Scala sequence.
- arrayToSeq(Class<?>[]) -
Static method in class akka.japi.Util
- Returns a Scala sequence representing the provided array of Classes,
an overloading of the generic arrayToSeq in Util, to accommodate for erasure.
- asByteBuffer() -
Method in class akka.util.ByteString
- Returns a read-only ByteBuffer that directly wraps this ByteString
if it is not fragmented.
- asByteBuffer() -
Method in class akka.util.ByteString.ByteString1
-
- asByteBuffer() -
Method in class akka.util.ByteString.ByteString1C
-
- asByteBuffer() -
Method in class akka.util.ByteString.ByteStrings
-
- asInputStream() -
Method in class akka.util.ByteIterator
- Directly wraps this ByteIterator in an InputStream without copying.
- asInputStream() -
Method in class akka.util.ByteIterator.ByteArrayIterator
-
- asInputStream() -
Method in class akka.util.ByteIterator.MultiByteArrayIterator
-
- asInt() -
Method in class akka.event.Logging.LogLevel
-
- ask(ActorRef) -
Method in interface akka.pattern.AskSupport
- Import this implicit conversion to gain
?
- ask(ActorRef, Object, Timeout) -
Method in interface akka.pattern.AskSupport
- Sends a message asynchronously and returns a
Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
- ask(Object, Timeout) -
Method in class akka.pattern.AskSupport.AskableActorRef
- Sends a message asynchronously and returns a
Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
- ask(ActorRef, Object, Timeout) -
Method in class akka.pattern.Patterns$
- Java API for
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
- ask(ActorRef, Object, long) -
Method in class akka.pattern.Patterns$
- Java API for
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
- ask(ActorRef, Object, Timeout) -
Static method in class akka.pattern.Patterns
- Java API for
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
- ask(ActorRef, Object, long) -
Static method in class akka.pattern.Patterns
- Java API for
akka.pattern.ask
:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender
reference provided.
- AskSupport - Interface in akka.pattern
- This object contains implementation details of the “ask” pattern.
- AskSupport.AskableActorRef - Class in akka.pattern
- Implementation detail of the “ask” pattern enrichment of ActorRef
- AskSupport.AskableActorRef(ActorRef) -
Constructor for class akka.pattern.AskSupport.AskableActorRef
-
- AskTimeoutException - Exception in akka.pattern
- This is what is used to complete a Future that is returned from an ask/?
- AskTimeoutException(String, Throwable) -
Constructor for exception akka.pattern.AskTimeoutException
-
- AskTimeoutException(String) -
Constructor for exception akka.pattern.AskTimeoutException
-
- asOutputStream() -
Method in class akka.util.ByteStringBuilder
- Directly wraps this ByteStringBuilder in an OutputStream.
- asReadable() -
Method in interface akka.actor.IO.Handle
-
- asReadable() -
Method in interface akka.actor.IO.ReadHandle
-
- asScala() -
Method in class akka.japi.Option
-
- asScala() -
Method in class akka.japi.Option.Some
-
- asServer() -
Method in interface akka.actor.IO.Handle
-
- asServer() -
Method in class akka.actor.IO.ServerHandle
-
- associate(ActorRef, ActorRef) -
Method in interface akka.event.ActorClassification
-
- asSocket() -
Method in interface akka.actor.IO.Handle
-
- asSocket() -
Method in class akka.actor.IO.SocketHandle
-
- asWritable() -
Method in interface akka.actor.IO.Handle
-
- asWritable() -
Method in interface akka.actor.IO.WriteHandle
-
- async(IO.Iteratee<A>, ExecutionContext) -
Method in class akka.actor.IO.IterateeRef$
- Creates an
IO.IterateeRefAsync
containing an initial
IO.Iteratee
.
- async(ExecutionContext) -
Method in class akka.actor.IO.IterateeRef$
- Creates an empty
IO.IterateeRefAsync
.
- async(ExecutionContext) -
Method in class akka.actor.IO.IterateeRef.Map$
- Creates an empty
IO.IterateeRefAsync
for each new key.
- atFullThrottle() -
Method in class akka.dispatch.ForkJoinExecutorConfigurator.AkkaForkJoinPool
-
- atomic(Function1<scala.concurrent.stm.InTxn, A>) -
Method in class akka.transactor.Coordinated
- Delimits the coordinated transaction.
- atomic(Runnable) -
Method in class akka.transactor.Coordinated
- Java API: coordinated atomic method that accepts a
java.lang.Runnable
.
- atomic(Callable<A>) -
Method in class akka.transactor.Coordinated
- Java API: coordinated atomic method that accepts a
java.util.concurrent.Callable
.
- atomically() -
Method in interface akka.transactor.Transactor
- The Receive block to run inside the coordinated transaction.
- atomically(Object) -
Method in class akka.transactor.UntypedTransactor
- The Receive block to run inside the coordinated transaction.
- atStartup() -
Method in class akka.actor.mailbox.DurableMailboxSpec
- May be implemented in concrete subclass to do additional things once before test
cases are run.
- atStartup() -
Method in class akka.testkit.AkkaSpec
-
- attach(akka.actor.ActorCell) -
Method in class akka.dispatch.MessageDispatcher
- Attaches the specified actor instance to this dispatcher, which includes
scheduling it to run for the first time (Create() is expected to have
been enqueued by the ActorCell upon mailbox creation).
- atTermination() -
Method in class akka.actor.mailbox.DurableMailboxSpec
- May be implemented in concrete subclass to do additional things once after all
test cases have been run.
- atTermination() -
Method in class akka.testkit.AkkaSpec
-
- AutoAck() -
Method in class akka.camel.CamelSettings
- Configured setting which determines whether one-way communications between an endpoint and this consumer actor
should be auto-acknowledged or application-acknowledged.
- autoAck() -
Method in interface akka.camel.Consumer
- Determines whether one-way communications between an endpoint and this consumer actor
should be auto-acknowledged or application-acknowledged.
- AutoDown() -
Method in class akka.cluster.ClusterSettings
-
- AutoJoin() -
Method in class akka.cluster.ClusterSettings
-
- autopilot() -
Method in class akka.testkit.TestActor
-
- await(Timeout) -
Method in class akka.agent.Agent
- Gets this agent's value after all currently queued updates have completed.
- await(ActorSystem) -
Method in class akka.testkit.TestBarrier
-
- await(FiniteDuration, ActorSystem) -
Method in class akka.testkit.TestBarrier
-
- await() -
Method in class akka.transactor.Coordinated
- An empty coordinated atomic block.
- awaitCond(Function0<Object>, Duration, Duration, boolean) -
Method in class akka.testkit.TestKit$
- Await until the given condition evaluates to
true
or the timeout
expires, whichever comes first.
- awaitCond(Function0<Object>, Duration, Duration, boolean) -
Static method in class akka.testkit.TestKit
- Await until the given condition evaluates to
true
or the timeout
expires, whichever comes first.
- awaitCond(Function0<Object>, Duration, Duration) -
Method in interface akka.testkit.TestKitBase
- Await until the given condition evaluates to
true
or the timeout
expires, whichever comes first.
- awaitDone(Duration) -
Method in class akka.testkit.EventFilter
-
- awaitTermination(Duration) -
Method in class akka.actor.ActorSystem
- Block current thread until the system has been shutdown, or the specified
timeout has elapsed.
- awaitTermination() -
Method in class akka.actor.ActorSystem
- Block current thread until the system has been shutdown.
- awaitTermination(long, TimeUnit) -
Method in interface akka.dispatch.ExecutorServiceDelegate
-
Backlog
option shall set the maximum length of the queue of outstanding peer connections
for the specified socket; this only applies to connection-oriented transports.backoffThreshold
and backoffRate
BalancingDispatcher
.T
.
Broadcast(...)- Broadcast(Object) -
Constructor for class akka.routing.Broadcast
-
- Broadcast$ - Class in akka.routing
-
- Broadcast$() -
Constructor for class akka.routing.Broadcast$
-
- BroadcastLike - Interface in akka.routing
- The core pieces of the routing logic is located in this
trait to be able to extend.
- BroadcastRouter - Class in akka.routing
- A Router that uses broadcasts a message to all its connections.
- BroadcastRouter(int, Iterable<String>, Option<Resizer>, String, SupervisorStrategy) -
Constructor for class akka.routing.BroadcastRouter
-
- BroadcastRouter(int) -
Constructor for class akka.routing.BroadcastRouter
- Java API: Constructor that sets nrOfInstances to be created.
- BroadcastRouter(Iterable<String>) -
Constructor for class akka.routing.BroadcastRouter
- Java API: Constructor that sets the routees to be used.
- BroadcastRouter(Resizer) -
Constructor for class akka.routing.BroadcastRouter
- Java API: Constructor that sets the resizer to be used.
- BroadcastRouter$ - Class in akka.routing
-
- BroadcastRouter$() -
Constructor for class akka.routing.BroadcastRouter$
-
- BrokenItemException - Exception in akka.actor.mailbox.filebased.filequeue
-
- BrokenItemException(long, Throwable) -
Constructor for exception akka.actor.mailbox.filebased.filequeue.BrokenItemException
-
- BrokenItemException$ - Class in akka.actor.mailbox.filebased.filequeue
-
- BrokenItemException$() -
Constructor for class akka.actor.mailbox.filebased.filequeue.BrokenItemException$
-
- build() -
Method in class akka.remote.RemoteProtocol.ActorRefProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.AddressProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.AkkaRemoteProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.DaemonMsgCreateProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.DeployProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.MessageProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.MetadataEntryProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.PropsProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.RemoteControlProtocol.Builder
-
- build() -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.ActorRefProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.AddressProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.AkkaRemoteProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.DaemonMsgCreateProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.DeployProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.MessageProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.MetadataEntryProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.PropsProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.RemoteControlProtocol.Builder
-
- buildPartial() -
Method in class akka.remote.RemoteProtocol.RemoteMessageProtocol.Builder
-
- BundleDelegatingClassLoader - Class in akka.osgi.impl
-
- BundleDelegatingClassLoader(org.osgi.framework.Bundle, Option<ClassLoader>) -
Constructor for class akka.osgi.impl.BundleDelegatingClassLoader
-
- BundleDelegatingClassLoader(org.osgi.framework.Bundle) -
Constructor for class akka.osgi.impl.BundleDelegatingClassLoader
-
- BundleDelegatingClassLoader$ - Class in akka.osgi.impl
-
- BundleDelegatingClassLoader$() -
Constructor for class akka.osgi.impl.BundleDelegatingClassLoader$
-
- bus() -
Method in class akka.event.BusLogging
-
- bus() -
Method in class akka.event.Logging.InitializeLogger
-
- BusLogging - Class in akka.event
-
- BusLogging(LoggingBus, String, Class<?>) -
Constructor for class akka.event.BusLogging
-
- ByteArraySerializer - Class in akka.serialization
- This is a special Serializer that Serializes and deserializes byte arrays only,
(just returns the byte array unchanged/uncopied)
- ByteArraySerializer() -
Constructor for class akka.serialization.ByteArraySerializer
-
- ByteIterator - Class in akka.util
- An iterator over a ByteString.
- ByteIterator() -
Constructor for class akka.util.ByteIterator
-
- ByteIterator$ - Class in akka.util
-
- ByteIterator$() -
Constructor for class akka.util.ByteIterator$
-
- ByteIterator.ByteArrayIterator - Class in akka.util
-
- ByteIterator.ByteArrayIterator$ - Class in akka.util
-
- ByteIterator.ByteArrayIterator$() -
Constructor for class akka.util.ByteIterator.ByteArrayIterator$
-
- ByteIterator.MultiByteArrayIterator - Class in akka.util
-
- ByteIterator.MultiByteArrayIterator$ - Class in akka.util
-
- ByteIterator.MultiByteArrayIterator$() -
Constructor for class akka.util.ByteIterator.MultiByteArrayIterator$
-
- bytes() -
Method in class akka.actor.IO.Chunk
-
- bytes() -
Method in class akka.actor.IO.Read
-
- bytes() -
Method in class akka.actor.IO.Write
-
- bytes() -
Method in class akka.actor.mailbox.filebased.filequeue.PersistentQueue
-
- bytesToHuman(long, long) -
Method in class akka.actor.mailbox.filebased.filequeue.tools.Util$
-
- bytesToHuman(long, long) -
Static method in class akka.actor.mailbox.filebased.filequeue.tools.Util
-
- bytesToInt(byte[], int) -
Method in class akka.util.Convert$
-
- bytesToInt(byte[], int) -
Static method in class akka.util.Convert
-
- bytesToLong(byte[]) -
Method in class akka.util.Convert$
-
- bytesToLong(byte[]) -
Static method in class akka.util.Convert
-
- ByteString - Class in akka.util
- A rope-like immutable data structure containing bytes.
- ByteString() -
Constructor for class akka.util.ByteString
-
- ByteString$ - Class in akka.util
-
- ByteString$() -
Constructor for class akka.util.ByteString$
-
- ByteString.ByteString1 - Class in akka.util
- An unfragmented ByteString.
- ByteString.ByteString1C - Class in akka.util
- A compact (unsliced) and unfragmented ByteString, implementation of ByteString1C.
- ByteString.ByteStrings - Class in akka.util
- A ByteString with 2 or more fragments.
- ByteStringBuilder - Class in akka.util
- A mutable builder for efficiently creating a
ByteString
. - ByteStringBuilder() -
Constructor for class akka.util.ByteStringBuilder
-
- bytestrings() -
Method in class akka.util.ByteString.ByteStrings
-
CircuitBreaker.withCircuitBreaker(scala.Function0>)
CircuitBreaker.withSyncCircuitBreaker(scala.Function0)
TimerTask
associated with this handle.
maxFailures
count is reached.IOManager
to close the Channel
associated with this IO.Handle
.
ClusterActorRefProvider
will load the Cluster
extension, i.e. the cluster will automatically be started when
the ClusterActorRefProvider
is used.RouterConfig
implementation for deployment on cluster nodes.totalInstances
of cluster router must be > 0
maxInstancesPerNode
of cluster router must be > 0
maxInstancesPerNode
of cluster router must be 1 when routeesPath is definedDeploy
with FSM
type parameterswith FSM
type parametersConcurrentMap
which is similar to
ConcurrentHashMap
.hashMapping
when
constructing the ConsistentHashingRouter
the messages need to implement this interface to define what
data to use for the consistent hash key.hashMapping
when
constructing the ConsistentHashingRouter
and messages can't implement ConsistentHashingRouter.ConsistentHashable
themselves they can we wrapped by this envelope instead.Coordinated
is a message wrapper that adds a CommitBarrier
for explicitly
coordinating transactions across actors or threads.Props
from the handOverData
sent from
previous singleton.
ActorSystem
, using the name specified
ActorSystem
, using the name specified.
Class[_]
object and a constructor description
will create a new instance of that class.
args
argument.
RouteeProvider
responsible for creating or
looking up routees.
Props
and registers them.
Actor
with Stash
,
since just using actor()(new Act with Stash{})
will not be able to see the
Stash component due to type erasure.source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Debug events, the most efficient is to use Left("")
.ActorRef
from Akka's protobuf representation in the supplied
ActorSystem
.
ActorRef
from Akka's protobuf representation in the supplied
ActorSystem
.
Dispatcher
binds a set of Actors to a thread pool backed up by a
BlockingQueue
.Dispatcher
.instance
.
Logging.LogEvent
when the string representation was supplied
directly.
akka {
actor {
my-durable-dispatcher {
mailbox-type = "my.durable.mailbox"
my-durable-mailbox {
setting1 = 1
setting2 = 2
}
}
}
}
where name=“my-durable-mailbox” in this example.ReflectiveDynamicAccess
is the default implementation).Set
view of the mappings contained in this map.
throwable
applies an upper bound on the type of exception contained in the Error event
source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either
with String.startsWith or Regex.findFirstIn().isDefined); if the message
itself does not match, the match is retried with the contained Exception’s
message; if both are null
, the filter always matches if at
the same time the Exception’s stack trace is empty (this catches
JVM-omitted “fast-throw” exceptions)
If you want to match all Error events, the most efficient is to use Left("")
.expectMsg(remaining, obj)
, but correctly treating the timeFactor.
expectMsgAllClassOf(remaining, obj...)
- expectMsgAllClassOf(FiniteDuration, Seq<Class<? extends T>>) -
Method in interface akka.testkit.TestKitBase
- Receive a number of messages from the test actor matching the given
number of classes and assert that for each given class one is received
which is of that class (equality, not conformance).
- expectMsgAllConformingOf(Seq<Class<? extends T>>) -
Method in interface akka.testkit.TestKitBase
- Same as
expectMsgAllConformingOf(remaining, obj...)
- expectMsgAllConformingOf(FiniteDuration, Seq<Class<? extends T>>) -
Method in interface akka.testkit.TestKitBase
- Receive a number of messages from the test actor matching the given
number of classes and assert that for each given class one is received
which conforms to that class (and vice versa).
- expectMsgAllOf(Object...) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgAllOf(FiniteDuration, Object...) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgAllOf(Seq<T>) -
Method in interface akka.testkit.TestKitBase
- Same as
expectMsgAllOf(remaining, obj...)
- expectMsgAllOf(FiniteDuration, Seq<T>) -
Method in interface akka.testkit.TestKitBase
- Receive a number of messages from the test actor matching the given
number of objects and assert that for each given object one is received
which equals it and vice versa.
- expectMsgAllOf_internal(FiniteDuration, Seq<T>) -
Method in interface akka.testkit.TestKitBase
-
- expectMsgAnyClassOf(Class<? extends T>...) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgAnyClassOf(FiniteDuration, Class<?>...) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgAnyClassOf(Seq<Class<? extends C>>) -
Method in interface akka.testkit.TestKitBase
- Same as
expectMsgAnyClassOf(remaining, obj...)
- expectMsgAnyClassOf(FiniteDuration, Seq<Class<? extends C>>) -
Method in interface akka.testkit.TestKitBase
- Receive one message from the test actor and assert that it conforms to
one of the given classes.
- expectMsgAnyClassOf_internal(FiniteDuration, Seq<Class<? extends C>>) -
Method in interface akka.testkit.TestKitBase
-
- expectMsgAnyOf(Object...) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgAnyOf(FiniteDuration, Object...) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgAnyOf(Seq<T>) -
Method in interface akka.testkit.TestKitBase
- Same as
expectMsgAnyOf(remaining, obj...)
- expectMsgAnyOf(FiniteDuration, Seq<T>) -
Method in interface akka.testkit.TestKitBase
- Receive one message from the test actor and assert that it equals one of
the given objects.
- expectMsgAnyOf_internal(FiniteDuration, Seq<T>) -
Method in interface akka.testkit.TestKitBase
-
- expectMsgClass(Class<T>) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgClass(FiniteDuration, Class<T>) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgClass(Class<C>) -
Method in interface akka.testkit.TestKitBase
- Same as
expectMsgClass(remaining, c)
, but correctly treating the timeFactor.
- expectMsgClass(FiniteDuration, Class<C>) -
Method in interface akka.testkit.TestKitBase
- Receive one message from the test actor and assert that it conforms to
the given class.
- expectMsgClass_internal(FiniteDuration, Class<C>) -
Method in interface akka.testkit.TestKitBase
-
- expectMsgEquals(T) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgEquals(FiniteDuration, T) -
Method in class akka.testkit.JavaTestKit
-
- expectMsgPF(Duration, String, PartialFunction<Object, T>) -
Method in interface akka.testkit.TestKitBase
- Receive one message from the test actor and assert that the given
partial function accepts it.
- expectMsgType(ClassTag<T>) -
Method in interface akka.testkit.TestKitBase
- Same as
expectMsgType[T](remaining)
, but correctly treating the timeFactor.
- expectMsgType(FiniteDuration, ClassTag<T>) -
Method in interface akka.testkit.TestKitBase
- Receive one message from the test actor and assert that it conforms to the
given type (after erasure).
- expectNoMsg() -
Method in class akka.testkit.JavaTestKit
-
- expectNoMsg(FiniteDuration) -
Method in class akka.testkit.JavaTestKit
-
- expectNoMsg() -
Method in interface akka.testkit.TestKitBase
- Same as
expectNoMsg(remaining)
, but correctly treating the timeFactor.
- expectNoMsg(FiniteDuration) -
Method in interface akka.testkit.TestKitBase
- Assert that no message is received for the specified time.
- expectNoMsg_internal(FiniteDuration) -
Method in interface akka.testkit.TestKitBase
-
- expiredQueue() -
Method in class akka.actor.mailbox.filebased.filequeue.PersistentQueue$
-
- expiredQueue() -
Method in class akka.actor.mailbox.filebased.filequeue.PersistentQueue
-
- expiry() -
Method in class akka.actor.mailbox.filebased.filequeue.QItem
-
- ExtendedActorSystem - Class in akka.actor
- More powerful interface to the actor system’s implementation which is presented to extensions (see
Extension
). - ExtendedActorSystem() -
Constructor for class akka.actor.ExtendedActorSystem
-
- extendHash(int, int, int, int) -
Method in class akka.routing.MurmurHash$
- Incorporates a new value into an existing hash.
- extendHash(int, int, int, int) -
Static method in class akka.routing.MurmurHash
- Incorporates a new value into an existing hash.
- extension(ExtensionId<T>) -
Method in class akka.actor.ActorSystem
- Returns the payload that is associated with the provided extension
throws an IllegalStateException if it is not registered.
- Extension - Interface in akka.actor
- The basic ActorSystem covers all that is needed for locally running actors,
using futures and so on.
- ExtensionId<T extends Extension> - Interface in akka.actor
- Identifies an Extension
Lookup of Extensions is done by object identity, so the Id must be the same wherever it's used,
otherwise you'll get the same extension loaded multiple times.
- ExtensionIdProvider - Interface in akka.actor
- To be able to load an ExtensionId from the configuration,
a class that implements ExtensionIdProvider must be specified.
- ExtensionKey<T extends Extension> - Class in akka.actor
- This is a one-stop-shop if all you want is an extension which is
constructed with the ExtendedActorSystem as its only constructor argument:
object MyExt extends ExtensionKey[Ext]
class Ext(system: ExtendedActorSystem) extends MyExt {
...
}
Java API:
public class MyExt extends Extension {
static final ExtensionKey<MyExt> key = new ExtensionKey<MyExt>(MyExt.class);
public MyExt(ExtendedActorSystem system) {
...
}
}
- ExtensionKey(ClassTag<T>) -
Constructor for class akka.actor.ExtensionKey
-
- ExtensionKey(Class<T>) -
Constructor for class akka.actor.ExtensionKey
-
- extractCpu(NodeMetrics) -
Method in class akka.cluster.StandardMetrics$
- Java API to extract Cpu data from nodeMetrics, if the nodeMetrics
contains necessary cpu metrics, otherwise it returns null.
- extractCpu(NodeMetrics) -
Static method in class akka.cluster.StandardMetrics
- Java API to extract Cpu data from nodeMetrics, if the nodeMetrics
contains necessary cpu metrics, otherwise it returns null.
- extractHeapMemory(NodeMetrics) -
Method in class akka.cluster.StandardMetrics$
- Java API to extract HeapMemory data from nodeMetrics, if the nodeMetrics
contains necessary heap metrics, otherwise it returns null.
- extractHeapMemory(NodeMetrics) -
Static method in class akka.cluster.StandardMetrics
- Java API to extract HeapMemory data from nodeMetrics, if the nodeMetrics
contains necessary heap metrics, otherwise it returns null.
- extractInterfaces(Class<?>) -
Method in class akka.actor.TypedProps$
-
- extractInterfaces(Class<?>) -
Static method in class akka.actor.TypedProps
-
- ExtractRoute - Class in akka.testkit
- This object can be used to extract the
Route
out of a RoutedActorRef. - ExtractRoute() -
Constructor for class akka.testkit.ExtractRoute
-
- ExtractRoute$ - Class in akka.testkit
- This object can be used to extract the
Route
out of a RoutedActorRef. - ExtractRoute$() -
Constructor for class akka.testkit.ExtractRoute$
-
- extraTime() -
Method in interface akka.actor.dsl.Inbox
-
Class
’s simple name.
Class
’s simple name.
Class
’s simple name.
Class
’s simple name.
akka.actor.FSM.SubscribeTransitionCallback
before sending any
FSM.Transition
messages.FSM
will be wrapped inside an
Event
, which allows pattern matching to extract both state and data.FSM
is shutting itself down because of
an error, e.g. if the state to transition into does not exist.LoggingFSM
, can be obtained by calling getLog
.stop()
.whenUnhandled
and onTermination
handlers.FSM
is shutting down.system.stop(fsm)
from outside;
also applies to Stop
supervision directive.FSM
: the state
name, the state data, possibly custom timeout, stop reason and replies
accumulated while processing the last message.FSM
whithin the
onTermination
block.FSM
to request first the akka.actor.CurrentState
and then a series of akka.actor.Transition
updates.akka.actor.FSM.SubscribeTransitionCallback
).FSM.Transition
notifications which was
effected by sending the corresponding akka.actor.FSM.SubscribeTransitionCallback
.Future
object with the result of that computation.
Future
object with the result of that computation.
akka.actor.IO.EOF
to this Iteratee and returns the
result if available.
null
if this map contains no mapping for the key.
Activation
interface
that can be used to wait on activation or de-activation of Camel endpoints.
Activation
interface
that can be used to wait on activation or de-activation of Camel endpoints.
ActorSystem
name will be set to bundle--ActorSystem
.
clazz
parameter.
org.apache.camel.impl.DefaultCamelContext
CamelContext
.
Class[_]
object loaded with the right class loader (i.e. the one
returned by classLoader
).
name
parameter.
names
.
org.apache.camel.ProducerTemplate
ProducerTemplate
.
Mapper
function that will be used as a route definition handler
for creating custom route to this consumer.
TimerTask
which is associated with this handle.
Timer
that created this handle.
Future
that will be completed with success (value true
) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future
that will be completed with success (value true
) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future
that will be completed with success (value true
) when
existing messages of the target actor has been processed and the actor has been
terminated.
true
), or it returns false
to escalate the
failure, which will lead to this actor re-throwing the exception which
caused the failure.
hashCode
.hashCode
.Timer
optimized for approximated I/O timeout scheduling.name
parameter in a Try
.
names
.
HighWatermark
option shall set the high water mark for the specified socket.Identity
valueSystem.identityHashCode
,
unless that happens to be the same for two non-equals objects, in which
case the supplied “real” comparator is used; the comparator must be
consistent with equals, otherwise it would not be an enhancement over
the identityHashCode.
System.identityHashCode
,
unless that happens to be the same for two non-equals objects, in which
case the supplied “real” comparator is used; the comparator must be
consistent with equals, otherwise it would not be an enhancement over
the identityHashCode.
source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Info events, the most efficient is to use Left("")
.null
is an invalid message.IOManager
to accept a new connection with the
given IO.SocketOption
s.IO.ServerSocketOption
to set the maximum backlog of connections. 0 or negative means that the platform default will be used.IO.Input
stream that contains a chunk of bytes.IOManager
to close the Channel.IOManager
that the Channel has closed.IOManager
to create a SocketChannel connected
to the provided address with the given IO.SocketOption
s.IOManager
that the SocketChannel has
successfully connected.IO.Input
stream that represents the end of the
stream.IO.Input
stream that represents an error in the stream.IO.Iteratee
that represents an erronous end state.IO.Iteratee
.IOManager
.IO.Iteratee
.IO.Iteratee
.IO.SocketOption
to enable or disable SO_KEEPALIVE
For more information see java.net.Socket.setKeepAlive
IOManager
to create a ServerSocketChannel
listening on the provided address with the given
IO.ServerSocketOption
s.IOManager
that the ServerSocketChannel is
now listening for connections.IOManager
that a new connection has been
made to the ServerSocketChannel and needs to be accepted.IO.Iteratee
that still requires more input to calculate
it's result.IO.SocketOption
to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data received on a IO.SocketHandle
is silently discarded.IO.SocketOption
to set performance preferences for this
IO.SocketHandle
.IOManager
that contains bytes read from
the SocketChannel.IO.Handle
to a ReadableByteChannel.IO.SocketOption
to set the SO_RCVBUF option for this
IO.SocketHandle
.IO.SocketOption
to enable or disable SO_REUSEADDR
For more information see java.net.Socket.setReuseAddress
IO.SocketOption
to set the SO_SNDBUF option for this
IO.SocketHandle
.IO.Handle
to a ServerSocketChannel.IO.ServerHandle
IO.Handle
to a SocketChannel.IO.SocketHandle
IO.SocketOption
to enable or disable SO_LINGER with the
specified linger time in seconds.IO.SocketOption
to set SO_TIMEOUT to the specified
timeout rounded down to the nearest millisecond.IO.SocketOption
to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)
For more information see java.net.Socket.setTcpNoDelay
IO.SocketOption
to set the traffic class or
type-of-service octet in the IP header for packets sent from this
IO.SocketHandle
.IOManager
to write to the SocketChannel.IO.Handle
to a WritableByteChannel.IOManagerActor
for
an ActorSystem
.Actor
that performs IO using a Java NIO Selector.Down
and not Removed
.
true
if and only if the TimerTask
associated
with this handle has been cancelled.
true
if and only if the TimerTask
associated
with this handle has been expired.
Logging
API available as the log
field, using java.util.logging
as the backend.java.util.logging
EventHandler.isCheck == true
and the latter to isCheck == false
for those cases where
this is important to know.ExtendedActorSystem
, because
that is the preferred constructor which will be invoked when reflectively instantiating
the JSerializer (also possible with empty constructor).Set
view of the keys contained in this map.
ActorSystem.eventStream
.
FSM
which adds a rolling event log and
debug logging capabilities (analogous to LoggingReceive
).Logging
’s apply
/create
method.LookupClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeMailbox
given the configuration.
transformer
function.
transformer
function.
true
) or not
(false
).
MulticastHops
MulticastLoop
Props
to build a ZeroMQ Dealer socket actor.
Props
to build a ZeroMQ Publisher socket actor.
Props
to build a ZeroMQ Pull socket actor.
Props
to build a ZeroMQ Push socket actor.
Props
to build a ZeroMQ Rep socket actor.
Props
to build a ZeroMQ Req socket actor.
Props
to build a ZeroMQ Router socket actor.
Props
to build the ZeroMQ socket actor.
Props
to build a ZeroMQ Subscriber socket actor.
TimerTask
for one-time execution after
the specified delay.
Option
factory that creates None
Option
factory that creates None
System.nanoTime
) as Duration.
ExecutionContext
supplied in the constructor.
Directive
(Resume, Restart, Stop) specified in the Decider
to the child actor that failed, as opposed to AllForOneStrategy
that applies
it to all children.ExecutionContext
supplied in the constructor.
ExecutionContext
supplied in the constructor.
endpointUri
.
getEndpointUri
.
Option
factory that creates None
if
v
is null
, Some(v)
otherwise.
Option
factory that creates None
if
v
is null
, Some(v)
otherwise.
Some[A]
represents existing values of type
A
.Member
ordering type class, sorts members by host and port.
Member
ordering type class, sorts members by host and port.
PostRestartException
.PostRestartException
.ByteString
of the request length,
but does not consume the Input.
ByteString
of the request length,
but does not consume the Input.
peek-dispatcher {
mailbox-type = "example.PeekMailboxType"
}
PinnedDispatcher
.Future
to send
the result to the given actor reference.
Future
to send
the result to the given actor reference.
pipeTo
method on Future
:
import akka.pattern.pipe
Future { doExpensiveCalc() } pipeTo nextActor
or
pipe(someFuture) to nextActor
preStart()
.
preStart()
.
preStart()
.
onTermination
hook; if you want to retain this behavior when
overriding make sure to call super.postStop()
.
postStop()
.'''
postStop()
.'''
postStop()
.'''
msg
to the endpoint specified by endpointUri
.
pattern
with the endpoint specified by
endpointUri
.
UntypedActorFactory
Class
com.google.protobuf.Message
sClusterEvent.ClusterDomainEvent
or ClusterEvent.CurrentClusterState
.
rampupRate
.
become
to change this.
receiver
actor.
ReceiveBufferSize
option shall set the underlying kernel receive buffer size for the socket to
the specified size in bytes.ReceiveBufferSize
ReceiveHighWatermark
option shall set the high water mark for inbound messages on the specified socket.receiveN(n, remaining)
but correctly taking into account
Duration.timeFactor.
ReconnectIVLMax
option shall set the maximum reconnection interval for the specified socket.RecoveryInterval
DynamicAccess
implementation used by ActorSystemImpl
unless overridden.Up
.
Up
.
within
block or missing that it returns the properly dilated default for this
case from settings (key "akka.test.single-expect-default").
within
block or missing that it returns the given duration.
RouterConfig
implementation for remote deployment on defined
target nodes.PoisonPill
after the specified delay.
RouterConfig
.Resizer
to use.
send
actions for the agent.
Router
actors.Router
.
endpointUri
.
Timer#newTimeout(TimerTask, long, java.util.concurrent.TimeUnit)
.
that
is tracking the same metric as this.
that
address is the same as this
ScanningClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeDeploy
serves two purposes: as a marker for
pattern matching the “scope” (i.e. local/remote/cluster) as well as for
extending the information carried by the final Deploy class.receiver
actor.
SendBufferSize
option shall set the underlying kernel transmit buffer size for the socket to
the specified size in bytes.SendBufferSize
SendHighWatermark
option shall set the high water mark for outbound messages on the specified socket.Seq
of Cause-Directive pairs to a Decider
.
Seq
of Throwables to a Decider
.
Seq
of Throwables to a Decider
.
Futures$.traverse(java.lang.Iterable, akka.japi.Function>, scala.concurrent.ExecutionContext)
.
Futures.traverse(java.lang.Iterable, akka.japi.Function>, scala.concurrent.ExecutionContext)
.
ActorRef
to Akka's
protobuf representation.
ActorRef
to Akka's
protobuf representation.
ReceiveTimeout
message is triggered.
Option
factory that creates Some
Option
factory that creates Some
Stash
trait enables an actor to temporarily stash away messages that can not or
should not be handled using the actor's current behavior.ActorRef
; this is
an asynchronous operation, i.e. involves a message send.
Timer
and cancels all
tasks which were scheduled but not executed yet.
SubchannelClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeSubscribe
option establishes a new message filter on a akka.zeromq.SocketType.Pub
socket./user
).send
actions for the agent.
Swap
option shall set the disk offload (swap) size for the specified socket.Swap
IO.IterateeRefSync
containing an initial
IO.Iteratee
.
IO.IterateeRefSync
.
IO.IterateeRefSync
for each new key.
null
if
there is nobody to reply to).
Terminated
to non-watching testActor is not possible,
and therefore the Terminated
message is wrapped.Terminated
to non-watching testActor is not possible,
and therefore the Terminated
message is wrapped.Mute
to the TestEventListener to install a filter, and UnMute
to
deinstall it.Mute
to the TestEventFilter to install a filter, and UnMute
to
deinstall it.TestKit
class: you may use
this if inheriting from a concrete class is not possible.Throttler
's.Throttler
.Throttler
.TimerTask
that is returned by a
Timer
.TimerTask
s for one-time future execution in a background
thread.Throttler
that uses a timer to control the message delivery rate.Timer#newTimeout(TimerTask, long, java.util.concurrent.TimeUnit)
.endpointUri
.
TypedActor.MethodCall
to the provided ActorRef.
subscribe
registration.
Unsubscribe
option shall remove an existing message filter
on a akka.zeromq.SocketType.Sub
socket.Actor
Scala interface.Collection
view of the values contained in this map.
source
, if given, applies a filter on the event’s origin
message
applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Warning events, the most efficient is to use Left("")
.preRestart
action with the supplied function.
postRestart
action with the supplied function.
preStart
action with the supplied thunk.
postStop
action with the supplied thunk.
body
converted to type T
.
body
converted to type clazz
.
Deploy
instances using
withFallback()
on
the left one, this is propagated to “merging” scopes in the same way.
headers
.
min
and
max
.
within(0 seconds, max)(f)
.
akka.routing.ConsistantHash
IOManager
to write to the
Channel associated with this IO.Handle
.
ExtensionId
and ExtensionIdProvider
for the ZeroMQ module
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |