public interface ClusterRouterConfigBase extends RouterConfig
Modifier and Type | Method and Description |
---|---|
Router |
createRouter(ActorSystem system)
Create the actual router, responsible for routing messages to routees.
|
boolean |
isManagementMessage(java.lang.Object msg)
Is the message handled by the router head actor or the
RouterConfig.routingLogicController(akka.routing.RoutingLogic) actor. |
RouterConfig |
local() |
java.lang.String |
routerDispatcher()
Dispatcher ID to use for running the “head” actor, which handles
supervision, death watch and router management messages
|
scala.Option<Props> |
routingLogicController(RoutingLogic routingLogic)
Possibility to define an actor for controlling the routing
logic from external stimuli (e.g.
|
ClusterRouterSettingsBase |
settings() |
boolean |
stopRouterWhenAllRouteesRemoved() |
createRouterActor, verifyConfig, withFallback
RouterConfig local()
ClusterRouterSettingsBase settings()
Router createRouter(ActorSystem system)
RouterConfig
createRouter
in interface RouterConfig
system
- the ActorSystem this router belongs tojava.lang.String routerDispatcher()
RouterConfig
routerDispatcher
in interface RouterConfig
boolean stopRouterWhenAllRouteesRemoved()
stopRouterWhenAllRouteesRemoved
in interface RouterConfig
scala.Option<Props> routingLogicController(RoutingLogic routingLogic)
RouterConfig
routingLogicController
in interface RouterConfig
routingLogic
- (undocumented)boolean isManagementMessage(java.lang.Object msg)
RouterConfig
RouterConfig.routingLogicController(akka.routing.RoutingLogic)
actor.isManagementMessage
in interface RouterConfig
msg
- (undocumented)