Utility function that tries to load the specified dispatcher config from the akka.
Utility function that tries to load the specified dispatcher config from the akka.conf or else use the supplied default dispatcher
Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.
Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.
Has a fluent builder interface for configuring its semantics.
Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.
Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.
Has a fluent builder interface for configuring its semantics.
Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.
Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.
Has a fluent builder interface for configuring its semantics.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Has a fluent builder interface for configuring its semantics.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Has a fluent builder interface for configuring its semantics.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Has a fluent builder interface for configuring its semantics.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.
Has a fluent builder interface for configuring its semantics.
Creates an thread based dispatcher serving a single actor through the same single thread.
Creates an thread based dispatcher serving a single actor through the same single thread. If capacity is negative, it's Integer.MAX_VALUE
E.g. each actor consumes its own thread.
Creates an thread based dispatcher serving a single actor through the same single thread.
Creates an thread based dispatcher serving a single actor through the same single thread. Uses the default timeout If capacity is negative, it's Integer.MAX_VALUE
E.g. each actor consumes its own thread.
Creates an thread based dispatcher serving a single actor through the same single thread.
Creates an thread based dispatcher serving a single actor through the same single thread. Uses the default timeout
E.g. each actor consumes its own thread.
Scala API. Dispatcher factory.
Example usage:
val dispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher("name") dispatcher .withNewThreadPoolWithLinkedBlockingQueueWithCapacity(100) .setCorePoolSize(16) .setMaxPoolSize(128) .setKeepAliveTimeInMillis(60000) .buildJava API. Dispatcher factory.
Example usage:
MessageDispatcher dispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher("name"); dispatcher .withNewThreadPoolWithLinkedBlockingQueueWithCapacity(100) .setCorePoolSize(16) .setMaxPoolSize(128) .setKeepAliveTimeInMillis(60000) .build();