akka

dispatch

package dispatch

Visibility
  1. Public
  2. All

Type Members

  1. class BalancingDispatcher extends Dispatcher

    An executor based event driven dispatcher which will try to redistribute work from busy actors to idle actors.

  2. class BalancingDispatcherConfigurator extends MessageDispatcherConfigurator

    Configurator for creating akka.dispatch.BalancingDispatcher.

  3. case class BoundedDequeBasedMailbox(capacity: Int, pushTimeOut: FiniteDuration) extends MailboxType with Product with Serializable

    BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque.

  4. trait BoundedDequeBasedMessageQueueSemantics extends DequeBasedMessageQueue

    BoundedMessageQueueSemantics adds bounded semantics to a DequeBasedMessageQueue, i.

  5. case class BoundedMailbox(capacity: Int, pushTimeOut: FiniteDuration) extends MailboxType with Product with Serializable

    BoundedMailbox is the default bounded MailboxType used by Akka Actors.

  6. trait BoundedMessageQueueSemantics extends QueueBasedMessageQueue

    BoundedMessageQueueSemantics adds bounded semantics to a QueueBasedMessageQueue, i.

  7. class BoundedPriorityMailbox extends MailboxType

    BoundedPriorityMailbox is a bounded mailbox that allows for priorization of its contents.

  8. trait DequeBasedMessageQueue extends QueueBasedMessageQueue

    DequeBasedMessageQueue refines QueueBasedMessageQueue to be backed by a java.

  9. class Dispatcher extends MessageDispatcher

    The event-based Dispatcher binds a set of Actors to a thread pool backed up by a BlockingQueue.

  10. class DispatcherConfigurator extends MessageDispatcherConfigurator

    Configurator for creating akka.dispatch.Dispatcher.

  11. trait DispatcherPrerequisites extends AnyRef

    DispatcherPrerequisites represents useful contextual pieces when constructing a MessageDispatcher

  12. class Dispatchers extends AnyRef

    Dispatchers are to be defined in configuration to allow for tuning for different environments.

  13. final case class Envelope extends Product with Serializable

  14. abstract class ExecutorServiceConfigurator extends ExecutorServiceFactoryProvider

    An ExecutorServiceConfigurator is a class that given some prerequisites and a configuration can create instances of ExecutorService

  15. trait ExecutorServiceDelegate extends ExecutorService

    As the name says

  16. trait ExecutorServiceFactory extends AnyRef

    Function0 without the fun stuff (mostly for the sake of the Java API side of things)

  17. trait ExecutorServiceFactoryProvider extends AnyRef

    Generic way to specify an ExecutorService to a Dispatcher, create it with the given name if desired

  18. abstract class Foreach[-T] extends UnitFunctionBridge[T]

    Callback for the Future.

  19. class ForkJoinExecutorConfigurator extends ExecutorServiceConfigurator

  20. trait MailboxType extends AnyRef

    MailboxType is a factory to create MessageQueues for an optionally provided ActorContext.

  21. abstract class Mapper[-T, +R] extends AbstractFunction1[T, R]

    Callback for the Future.

  22. abstract class MessageDispatcher extends AbstractMessageDispatcher with BatchingExecutor with ExecutionContext

  23. abstract class MessageDispatcherConfigurator extends AnyRef

    Base class to be used for hooking in new dispatchers into Dispatchers.

  24. trait MessageQueue extends AnyRef

    A MessageQueue is one of the core components in forming an Akka Mailbox.

  25. case class MonitorableThreadFactory(name: String, daemonic: Boolean, contextClassLoader: Option[ClassLoader], exceptionHandler: UncaughtExceptionHandler = MonitorableThreadFactory.doNothing, counter: AtomicLong = ...) extends ThreadFactory with ForkJoinWorkerThreadFactory with Product with Serializable

  26. abstract class OnComplete[-T] extends CallbackBridge[Try[T]]

    Callback for when a Future is completed with either failure or a success SAM (Single Abstract Method) class

  27. abstract class OnFailure extends CallbackBridge[Throwable]

    Callback for when a Future is completed with a failure SAM (Single Abstract Method) class

  28. abstract class OnSuccess[-T] extends CallbackBridge[T]

    Callback for when a Future is completed successfully SAM (Single Abstract Method) class

  29. class PinnedDispatcher extends Dispatcher

    Dedicates a unique thread for each actor passed in as reference.

  30. class PinnedDispatcherConfigurator extends MessageDispatcherConfigurator

    Configurator for creating akka.dispatch.PinnedDispatcher.

  31. abstract class PriorityGenerator extends Comparator[Envelope]

    A PriorityGenerator is a convenience API to create a Comparator that orders the messages of a PriorityDispatcher

  32. trait QueueBasedMessageQueue extends MessageQueue

    A QueueBasedMessageQueue is a MessageQueue backed by a java.

  33. abstract class Recover[+T] extends RecoverBridge[T]

    Callback for the Future.

  34. class SaneRejectedExecutionHandler extends RejectedExecutionHandler

    The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy by throwing a RejectedExecutionException if the executor isShutdown.

  35. final case class TaskInvocation(eventStream: EventStream, runnable: Runnable, cleanup: () ⇒ Unit) extends Batchable with Product with Serializable

  36. case class ThreadPoolConfig(allowCorePoolTimeout: Boolean = ..., corePoolSize: Int = ..., maxPoolSize: Int = ThreadPoolConfig.defaultMaxPoolSize, threadTimeout: Duration = ThreadPoolConfig.defaultTimeout, queueFactory: () ⇒ BlockingQueue[Runnable] = ..., rejectionPolicy: RejectedExecutionHandler = ...) extends ExecutorServiceFactoryProvider with Product with Serializable

    A small configuration DSL to create ThreadPoolExecutors that can be provided as an ExecutorServiceFactoryProvider to Dispatcher

  37. case class ThreadPoolConfigBuilder(config: ThreadPoolConfig) extends Product with Serializable

    A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor

  38. class ThreadPoolExecutorConfigurator extends ExecutorServiceConfigurator

  39. case class UnboundedDequeBasedMailbox() extends MailboxType with Product with Serializable

    UnboundedDequeBasedMailbox is an unbounded MailboxType, backed by a Deque.

  40. trait UnboundedDequeBasedMessageQueueSemantics extends DequeBasedMessageQueue

    UnboundedDequeBasedMessageQueueSemantics adds unbounded semantics to a DequeBasedMessageQueue, i.

  41. case class UnboundedMailbox() extends MailboxType with Product with Serializable

    UnboundedMailbox is the default unbounded MailboxType used by Akka Actors.

  42. trait UnboundedMessageQueueSemantics extends QueueBasedMessageQueue

    UnboundedMessageQueueSemantics adds unbounded semantics to a QueueBasedMessageQueue, i.

  43. class UnboundedPriorityMailbox extends MailboxType

    UnboundedPriorityMailbox is an unbounded mailbox that allows for priorization of its contents.

Value Members

  1. object Dispatchers

  2. object Envelope extends Serializable

  3. object ExecutionContexts

    ExecutionContexts is the Java API for ExecutionContexts

  4. object Filter

    Java API (not recommended): Callback for the Future.

  5. object ForkJoinExecutorConfigurator

  6. object Futures

    Futures is the Java API for Futures and Promises

  7. object MonitorableThreadFactory extends Serializable

  8. object NullMessage extends AutoReceivedMessage with Product with Serializable

    This message is sent directly after the Supervise system message in order to form a barrier wrt.

  9. object PriorityGenerator

  10. object ThreadPoolConfig extends Serializable

  11. object ThreadPoolConfigBuilder extends Serializable

  12. object japi

    This class contains bridge classes between Scala and Java.

Ungrouped