Package akka.cluster.routing
Interface ClusterRouterConfigBase
-
- All Superinterfaces:
RouterConfig
,java.io.Serializable
- All Known Implementing Classes:
ClusterRouterGroup
,ClusterRouterPool
public interface ClusterRouterConfigBase extends RouterConfig
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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 theRouterConfig.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 messagesscala.Option<Props>
routingLogicController(RoutingLogic routingLogic)
Possibility to define an actor for controlling the routing logic from external stimuli (e.g.ClusterRouterSettingsBase
settings()
boolean
stopRouterWhenAllRouteesRemoved()
boolean
super$isManagementMessage(java.lang.Object msg)
-
Methods inherited from interface akka.routing.RouterConfig
createRouterActor, verifyConfig, withFallback
-
-
-
-
Method Detail
-
createRouter
Router createRouter(ActorSystem system)
Description copied from interface:RouterConfig
Create the actual router, responsible for routing messages to routees.- Specified by:
createRouter
in interfaceRouterConfig
- Parameters:
system
- the ActorSystem this router belongs to
-
isManagementMessage
boolean isManagementMessage(java.lang.Object msg)
Description copied from interface:RouterConfig
Is the message handled by the router head actor or theRouterConfig.routingLogicController(akka.routing.RoutingLogic)
actor.- Specified by:
isManagementMessage
in interfaceRouterConfig
-
local
RouterConfig local()
-
routerDispatcher
java.lang.String routerDispatcher()
Description copied from interface:RouterConfig
Dispatcher ID to use for running the “head” actor, which handles supervision, death watch and router management messages- Specified by:
routerDispatcher
in interfaceRouterConfig
-
routingLogicController
scala.Option<Props> routingLogicController(RoutingLogic routingLogic)
Description copied from interface:RouterConfig
Possibility to define an actor for controlling the routing logic from external stimuli (e.g. monitoring metrics). This actor will be a child of the router "head" actor. Management messages not handled by the "head" actor are delegated to this controller actor.- Specified by:
routingLogicController
in interfaceRouterConfig
-
settings
ClusterRouterSettingsBase settings()
-
stopRouterWhenAllRouteesRemoved
boolean stopRouterWhenAllRouteesRemoved()
- Specified by:
stopRouterWhenAllRouteesRemoved
in interfaceRouterConfig
-
super$isManagementMessage
boolean super$isManagementMessage(java.lang.Object msg)
-
-