Interface Summary |
ConsistentHashingRouter.ConsistentHashable |
If you don't define the hashMapping when
constructing the ConsistentHashingRouter
the messages need to implement this interface to define what
data to use for the consistent hash key. |
ConsistentHashingRouter.ConsistentHashMapper |
JAVA API
Mapping from message to the data to use for the consistent hash key. |
DeprecatedRouterConfig |
|
Group |
RouterConfig for router actor with routee actors that are created external to the
router and the router sends messages to the specified path using actor selection,
without watching for termination. |
ListenerMessage |
|
Listeners |
Listeners is a generic trait to implement listening capability on an Actor. |
Pool |
RouterConfig for router actor that creates routees as child actors and removes
them from the router if they terminate. |
PoolOverrideUnsetConfig<T extends Pool> |
INTERNAL API |
Resizer |
Pool routers with dynamically resizable number of routees are implemented by providing a Resizer
implementation in the Pool configuration. |
Routee |
Abstraction of a destination for messages routed via a Router . |
RouterConfig |
This trait represents a router factory: it produces the actual router actor
and creates the routing table (a function which determines the recipients
for each message which is to be dispatched). |
RouterEnvelope |
Only the contained message will be forwarded to the
destination, i.e. |
RouterManagementMesssage |
INTERNAL API |
RoutingLogic |
The interface of the routing logic that is used in a Router to select
destination routed messages. |
Class Summary |
ActorRefRoutee |
Routee that sends the messages to an ActorRef . |
ActorRefRoutee$ |
|
ActorSelectionRoutee |
Routee that sends the messages to an ActorSelection . |
ActorSelectionRoutee$ |
|
AddRoutee |
Add a routee by sending this message to the router. |
AddRoutee$ |
|
AdjustPoolSize |
Increase or decrease the number of routees in a Pool . |
AdjustPoolSize$ |
|
BalancingPool |
A router pool that will try to redistribute work from busy routees to idle routees. |
BalancingPool$ |
|
BalancingRoutingLogic |
INTERNAL API
Selects the first routee, balancing will be done by the dispatcher. |
BalancingRoutingLogic$ |
INTERNAL API |
Broadcast |
Used to broadcast a message to all routees in a router; only the
contained message will be forwarded, i.e. |
Broadcast$ |
|
BroadcastGroup |
A router group that broadcasts a message to all its routees. |
BroadcastGroup$ |
|
BroadcastPool |
A router pool that broadcasts a message to all its routees. |
BroadcastPool$ |
|
BroadcastRouter |
|
BroadcastRouter$ |
|
BroadcastRoutingLogic |
Broadcasts a message to all its routees. |
BroadcastRoutingLogic$ |
|
CollectRouteeRefs |
INTERNAL API
Backwards compatibility glue to support CurrentRoutees/RouterRoutees containing refs of
the routees. |
ConsistentActorRef |
INTERNAL API
Important to use ActorRef with full address, with host and port, in the hash ring,
so that same ring is produced on different nodes. |
ConsistentActorRef$ |
|
ConsistentHash<T> |
Consistent Hashing node ring implementation. |
ConsistentHash$ |
|
ConsistentHashingGroup |
|
ConsistentHashingGroup$ |
|
ConsistentHashingPool |
|
ConsistentHashingPool$ |
|
ConsistentHashingRouter |
|
ConsistentHashingRouter.ConsistentHashableEnvelope |
If you don't define the hashMapping when
constructing the ConsistentHashingRouter
and messages can't implement ConsistentHashingRouter.ConsistentHashable
themselves they can we wrapped by this envelope instead. |
ConsistentHashingRouter.ConsistentHashableEnvelope$ |
|
ConsistentHashingRouter.emptyConsistentHashMapping$ |
|
ConsistentHashingRouter$ |
|
ConsistentHashingRoutingLogic |
|
ConsistentHashingRoutingLogic$ |
|
ConsistentRoutee |
|
ConsistentRoutee$ |
|
CurrentRoutees |
Sending this message to a router will make it send back its currently used routees. |
CurrentRoutees$ |
|
CustomRouterConfig |
If a custom router implementation is not a Group nor
a Pool it may extend this base class. |
Deafen |
|
Deafen$ |
|
DefaultResizer |
|
DefaultResizer$ |
|
FromConfig |
Java API: Router configuration which has no default, i.e. |
FromConfig$ |
Router configuration which has no default, i.e. |
GetRoutees |
Sending this message to a router will make it send back its currently used routees. |
GetRoutees$ |
|
GroupBase |
Java API: Base class for custom router Group |
Listen |
|
Listen$ |
|
MurmurHash |
An object designed to generate well-distributed non-cryptographic
hashes. |
MurmurHash$ |
An object designed to generate well-distributed non-cryptographic
hashes. |
NoRoutee |
Routee that doesn't send the message to any routee. |
NoRoutee$ |
Routee that doesn't send the message to any routee. |
NoRouter |
Routing configuration that indicates no routing; this is also the default
value which hence overrides the merge strategy in order to accept values
from lower-precedence sources. |
NoRouter$ |
|
Pool$ |
|
PoolBase |
Java API: Base class for custom router Pool |
RandomGroup |
A router group that randomly selects one of the target routees to send a message to. |
RandomGroup$ |
|
RandomPool |
A router pool that randomly selects one of the target routees to send a message to. |
RandomPool$ |
|
RandomRouter |
|
RandomRouter$ |
|
RandomRoutingLogic |
Randomly selects one of the target routees to send a message to |
RandomRoutingLogic$ |
|
RemoveRoutee |
Remove a specific routee by sending this message to the router. |
RemoveRoutee$ |
|
ResizablePoolActor |
INTERNAL API |
ResizablePoolActor.Resize$ |
|
ResizablePoolActor$ |
INTERNAL API |
ResizablePoolCell |
INTERNAL API |
RoundRobinGroup |
A router group that uses round-robin to select a routee. |
RoundRobinGroup$ |
|
RoundRobinPool |
A router pool that uses round-robin to select a routee. |
RoundRobinPool$ |
|
RoundRobinRouter |
|
RoundRobinRouter$ |
|
RoundRobinRoutingLogic |
Uses round-robin to select a routee. |
RoundRobinRoutingLogic$ |
|
RoutedActorCell |
INTERNAL API |
RoutedActorCell.RouterActorCreator |
|
RoutedActorCell$ |
INTERNAL API |
RoutedActorRef |
INTERNAL API |
Routees |
Message used to carry information about what routees the router is currently using. |
Routees$ |
|
Router |
For each message that is sent through the router via the Router.route(java.lang.Object, akka.actor.ActorRef) method the
RoutingLogic decides to which Routee to send the message. |
Router$ |
|
RouterActor |
INTERNAL API |
RouterPoolActor |
INTERNAL API |
RouterRoutees |
Message used to carry information about what routees the router is currently using. |
RouterRoutees$ |
|
ScatterGatherFirstCompletedGroup |
A router group that broadcasts the message to all routees, and replies with the first response. |
ScatterGatherFirstCompletedGroup$ |
|
ScatterGatherFirstCompletedPool |
A router pool that broadcasts the message to all routees, and replies with the first response. |
ScatterGatherFirstCompletedPool$ |
|
ScatterGatherFirstCompletedRoutees |
INTERNAL API |
ScatterGatherFirstCompletedRoutees$ |
|
ScatterGatherFirstCompletedRouter |
|
ScatterGatherFirstCompletedRouter$ |
|
ScatterGatherFirstCompletedRoutingLogic |
Broadcasts the message to all routees, and replies with the first response. |
ScatterGatherFirstCompletedRoutingLogic$ |
|
SeveralRoutees |
Routee that sends each message to all routees . |
SeveralRoutees$ |
|
SmallestMailboxPool |
A router pool that tries to send to the non-suspended routee with fewest messages in mailbox. |
SmallestMailboxPool$ |
|
SmallestMailboxRouter |
|
SmallestMailboxRouter$ |
|
SmallestMailboxRoutingLogic |
Tries to send to the non-suspended routee with fewest messages in mailbox. |
SmallestMailboxRoutingLogic$ |
|
TailChoppingGroup |
A router group that sends the message to a first, random picked, routee,
then wait a specified interval and then send to a second, random picked, and so on till one full cycle.. |
TailChoppingGroup$ |
|
TailChoppingPool |
A router poll thats sends the message to a first, random picked, routee,
then wait a specified interval and then send to a second, random picked, and so on till one full cycle.. |
TailChoppingPool$ |
|
TailChoppingRoutees |
INTERNAL API |
TailChoppingRoutees$ |
|
TailChoppingRoutingLogic |
Sends the message to a first, random picked, routee,
then wait a specified interval and then send to a second, random picked, and so on till one full cycle. |
TailChoppingRoutingLogic$ |
|
WithListeners |
|
WithListeners$ |
|