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.