Package akka.dispatch

Interface Summary

BoundedDequeBasedMessageQueueSemantics	BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.e. blocking enqueue with timeout
BoundedMessageQueueSemantics	BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i.e. blocking enqueue with timeout
DequeBasedMessageQueue	DequeBasedMessageQueue refines QueueBasedMessageQueue to be backed by a java.util.Deque
DispatcherPrerequisites	DispatcherPrerequisites represents useful contextual pieces when constructing a MessageDispatcher
ExecutorServiceDelegate	As the name says
ExecutorServiceFactory	Function0 without the fun stuff (mostly for the sake of the Java API side of things)
ExecutorServiceFactoryProvider	Generic way to specify an ExecutorService to a Dispatcher, create it with the given name if desired
MailboxType	MailboxType is a factory to create MessageQueues for an optionally provided ActorContext.
MessageQueue	A MessageQueue is one of the core components in forming an Akka Mailbox.
QueueBasedMessageQueue	A QueueBasedMessageQueue is a MessageQueue backed by a java.util.Queue
UnboundedDequeBasedMessageQueueSemantics	UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i.e. a non-blocking enqueue and dequeue.
UnboundedMessageQueueSemantics	UnboundedMessageQueueSemantics adds unbounded semantics to a QueueBasedMessageQueue, i.e. a non-blocking enqueue and dequeue.

Class Summary

BalancingDispatcher	An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors.
BalancingDispatcherConfigurator	Configurator for creating BalancingDispatcher.
BoundedDequeBasedMailbox	BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque.
BoundedDequeBasedMailbox$
BoundedMailbox	BoundedMailbox is the default bounded MailboxType used by Akka Actors.
BoundedMailbox$
BoundedPriorityMailbox	BoundedPriorityMailbox is a bounded mailbox that allows for priorization of its contents.
Dispatcher	The event-based Dispatcher binds a set of Actors to a thread pool backed up by a BlockingQueue.
DispatcherConfigurator	Configurator for creating Dispatcher.
Dispatchers	Dispatchers are to be defined in configuration to allow for tuning for different environments.
Dispatchers$
Envelope
Envelope$
ExecutionContexts	ExecutionContexts is the Java API for ExecutionContexts
ExecutionContexts$	ExecutionContexts is the Java API for ExecutionContexts
ExecutorServiceConfigurator	An ExecutorServiceConfigurator is a class that given some prerequisites and a configuration can create instances of ExecutorService
Filter	Java API (not recommended): Callback for the Future.filter operation that creates a new Future which will conditionally contain the success of another Future.
Filter$	Java API (not recommended): Callback for the Future.filter operation that creates a new Future which will conditionally contain the success of another Future.
Foreach<T>	Callback for the Future.foreach operation that will be invoked if the Future that this callback is registered on becomes completed with a success.
ForkJoinExecutorConfigurator
ForkJoinExecutorConfigurator.AkkaForkJoinPool	INTERNAL AKKA USAGE ONLY
ForkJoinExecutorConfigurator.MailboxExecutionTask	INTERNAL AKKA USAGE ONLY
ForkJoinExecutorConfigurator$
Futures	Futures is the Java API for Futures and Promises
Futures$	Futures is the Java API for Futures and Promises
japi	This class contains bridge classes between Scala and Java.
japi.BooleanFunctionBridge<T>
japi.CallbackBridge<T>
japi.RecoverBridge<T>
japi.UnitFunctionBridge<T>
japi$	This class contains bridge classes between Scala and Java.
Mapper<T,R>	Callback for the Future.map and Future.flatMap operations that will be invoked if the Future that this callback is registered on becomes completed with a success.
MessageDispatcher
MessageDispatcherConfigurator	Base class to be used for hooking in new dispatchers into Dispatchers.
MonitorableThreadFactory
MonitorableThreadFactory$
NullMessage	This message is sent directly after the Supervise system message in order to form a barrier wrt. the first real message sent by the child, so that e.g.
NullMessage$	This message is sent directly after the Supervise system message in order to form a barrier wrt. the first real message sent by the child, so that e.g.
OnComplete<T>	Callback for when a Future is completed with either failure or a success SAM (Single Abstract Method) class Java API
OnFailure	Callback for when a Future is completed with a failure SAM (Single Abstract Method) class Java API
OnSuccess<T>	Callback for when a Future is completed successfully SAM (Single Abstract Method) class Java API
PinnedDispatcher	Dedicates a unique thread for each actor passed in as reference.
PinnedDispatcherConfigurator	Configurator for creating PinnedDispatcher.
PriorityGenerator	A PriorityGenerator is a convenience API to create a Comparator that orders the messages of a PriorityDispatcher
PriorityGenerator$
Recover<T>	Callback for the Future.recover operation that conditionally turns failures into successes.
SaneRejectedExecutionHandler	The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy by throwing a RejectedExecutionException if the executor isShutdown.
TaskInvocation
TaskInvocation$
ThreadPoolConfig	A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher
ThreadPoolConfig$
ThreadPoolConfigBuilder	A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor
ThreadPoolConfigBuilder$
ThreadPoolExecutorConfigurator
UnboundedDequeBasedMailbox	UnboundedDequeBasedMailbox is an unbounded MailboxType, backed by a Deque.
UnboundedDequeBasedMailbox$
UnboundedMailbox	UnboundedMailbox is the default unbounded MailboxType used by Akka Actors.
UnboundedMailbox$
UnboundedPriorityMailbox	UnboundedPriorityMailbox is an unbounded mailbox that allows for priorization of its contents.