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 BalancingDispatcher.

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

  4. trait BoundedDequeBasedMessageQueueSemantics extends DequeBasedMessageQueue

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

  6. trait BoundedMessageQueueSemantics extends QueueBasedMessageQueue

  7. class BoundedPriorityMailbox extends MailboxType

    Extend me to provide the comparator

  8. case class ChildTerminated (child: ActorRef) extends SystemMessage with Product with Serializable

  9. case class Create () extends SystemMessage with Product with Serializable

  10. case class DefaultDispatcherPrerequisites (threadFactory: ThreadFactory, eventStream: EventStream, deadLetterMailbox: Mailbox, scheduler: Scheduler, dynamicAccess: DynamicAccess, settings: Settings) extends DispatcherPrerequisites with Product with Serializable

  11. class DefaultPromise [T] extends AbstractPromise with Promise[T]

    The default concrete Future implementation.

  12. trait DequeBasedMessageQueue extends QueueBasedMessageQueue

  13. class Dispatcher extends MessageDispatcher

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

  14. class DispatcherConfigurator extends MessageDispatcherConfigurator

    Configurator for creating Dispatcher.

  15. trait DispatcherPrerequisites extends AnyRef

  16. class Dispatchers extends AnyRef

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

  17. case class Envelope (message: Any, sender: ActorRef, system: ActorSystem) extends Product with Serializable

    Attributes
    final
  18. trait ExecutionContext extends AnyRef

    An ExecutionContext is essentially the same thing as a java.

  19. trait ExecutionContextExecutor extends ExecutionContext with Executor

    Union interface since Java does not support union types

  20. trait ExecutionContextExecutorService extends ExecutionContextExecutor with ExecutorService

    Union interface since Java does not support union types

  21. class ExecutorServiceConfigurator extends ExecutorServiceFactoryProvider

    Attributes
    abstract
  22. trait ExecutorServiceDelegate extends ExecutorService

    As the name says

  23. trait ExecutorServiceFactory extends AnyRef

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

  24. trait ExecutorServiceFactoryProvider extends AnyRef

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

  25. class Foreach [-T] extends UnitFunctionBridge[T]

    Callback for the Future.

  26. class ForkJoinExecutorConfigurator extends ExecutorServiceConfigurator

  27. trait Future [+T] extends Awaitable[T]

    Attributes
    sealed
  28. class KeptPromise [T] extends Promise[T]

    An already completed Future is seeded with it's result at creation, is useful for when you are participating in a Future-composition but you already have a value to contribute.

  29. case class Link (subject: ActorRef) extends SystemMessage with Product with Serializable

  30. trait MailboxType extends AnyRef

    Mailbox configuration.

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

    Callback for the Future.

  32. class MessageDispatcher extends AbstractMessageDispatcher with Executor with ExecutionContext

    Attributes
    abstract
  33. class MessageDispatcherConfigurator extends AnyRef

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

  34. trait MessageQueue extends AnyRef

  35. class MessageQueueAppendFailedException extends AkkaException

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

  37. class OnComplete [-T] extends CallbackBridge[Either[Throwable, T]]

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

  38. class OnFailure extends CallbackBridge[Throwable]

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

  39. class OnSuccess [-T] extends CallbackBridge[T]

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

  40. class PinnedDispatcher extends Dispatcher

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

  41. class PinnedDispatcherConfigurator extends MessageDispatcherConfigurator

    Configurator for creating PinnedDispatcher.

  42. class PriorityGenerator extends Comparator[Envelope]

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

  43. trait Promise [T] extends Future[T]

    Essentially this is the Promise (or write-side) of a Future (read-side).

  44. class PromiseStream [A] extends PromiseStreamOut[A] with PromiseStreamIn[A]

  45. trait PromiseStreamIn [A] extends AnyRef

  46. trait PromiseStreamOut [A] extends AnyRef

  47. trait QueueBasedMessageQueue extends MessageQueue

  48. class Recover [+T] extends RecoverBridge[T]

    Callback for the Future.

  49. case class Recreate (cause: Throwable) extends SystemMessage with Product with Serializable

  50. case class Resume () extends SystemMessage with Product with Serializable

  51. class SaneRejectedExecutionHandler extends RejectedExecutionHandler

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

  52. class SharingMailbox extends Mailbox with DefaultSystemMessageQueue

  53. case class Supervise (child: ActorRef) extends SystemMessage with Product with Serializable

  54. case class Suspend () extends SystemMessage with Product with Serializable

  55. trait SystemMessage extends PossiblyHarmful

    System messages are handled specially: they form their own queue within each actor’s mailbox.

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

    Attributes
    final
  57. case class Terminate () extends SystemMessage with Product with Serializable

  58. case class ThreadPoolConfig (allowCorePoolTimeout: Boolean, corePoolSize: Int, maxPoolSize: Int, threadTimeout: Duration, queueFactory: QueueFactory, rejectionPolicy: RejectedExecutionHandler) extends ExecutorServiceFactoryProvider with Product with Serializable

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

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

    A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor

  60. class ThreadPoolExecutorConfigurator extends ExecutorServiceConfigurator

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

  62. trait UnboundedDequeBasedMessageQueueSemantics extends DequeBasedMessageQueue

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

    It's a case class for Java (new UnboundedMailbox)

  64. trait UnboundedMessageQueueSemantics extends QueueBasedMessageQueue

  65. class UnboundedPriorityMailbox extends MailboxType

    Extend me to provide the comparator

  66. case class Unlink (subject: ActorRef) extends SystemMessage with Product with Serializable

  67. class FutureTimeoutException extends AkkaException

    Annotations
    @deprecated
    Deprecated

    Await throws java.util.concurrent.TimeoutException

  68. class OldFuture [T] extends AnyRef

    Some old methods made available through implicit conversion in migration.

Value Members

  1. object Await extends AnyRef

  2. object Dispatchers extends AnyRef

  3. object ExecutionContext extends AnyRef

  4. object ExecutionContexts extends AnyRef

    Java API to create ExecutionContexts

  5. object Filter extends AnyRef

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

  6. object ForkJoinExecutorConfigurator extends AnyRef

  7. object Future extends AnyRef

  8. object Futures extends AnyRef

    Futures is the Java API for Futures and Promises

  9. object Mailbox extends AnyRef

  10. object MessageDispatcher extends AnyRef

  11. object MonitorableThreadFactory extends Serializable

  12. object PriorityGenerator extends AnyRef

  13. object Promise extends AnyRef

  14. object PromiseStream extends AnyRef

  15. object SystemMessage extends AnyRef

  16. object ThreadPoolConfig extends Serializable

  17. object ThreadPoolConfigBuilder extends Serializable

  18. object japi extends AnyRef

    This class contains bridge classes between Scala and Java.