Package akka.cluster.routing
Class ClusterRouterPool
- java.lang.Object
-
- akka.cluster.routing.ClusterRouterPool
-
- All Implemented Interfaces:
ClusterRouterConfigBase
,Pool
,RouterConfig
,java.io.Serializable
,scala.Equals
,scala.Product
,scala.Serializable
public final class ClusterRouterPool extends java.lang.Object implements Pool, ClusterRouterConfigBase, scala.Product, scala.Serializable
INTERNAL API- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ClusterRouterPool(Pool local, ClusterRouterPoolSettings settings)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ClusterRouterPool
apply(Pool local, ClusterRouterPoolSettings settings)
static double
apply$mcDDD$sp(double v1, double v2)
static double
apply$mcDDI$sp(double v1, int v2)
static double
apply$mcDDJ$sp(double v1, long v2)
static double
apply$mcDID$sp(int v1, double v2)
static double
apply$mcDII$sp(int v1, int v2)
static double
apply$mcDIJ$sp(int v1, long v2)
static double
apply$mcDJD$sp(long v1, double v2)
static double
apply$mcDJI$sp(long v1, int v2)
static double
apply$mcDJJ$sp(long v1, long v2)
static float
apply$mcFDD$sp(double v1, double v2)
static float
apply$mcFDI$sp(double v1, int v2)
static float
apply$mcFDJ$sp(double v1, long v2)
static float
apply$mcFID$sp(int v1, double v2)
static float
apply$mcFII$sp(int v1, int v2)
static float
apply$mcFIJ$sp(int v1, long v2)
static float
apply$mcFJD$sp(long v1, double v2)
static float
apply$mcFJI$sp(long v1, int v2)
static float
apply$mcFJJ$sp(long v1, long v2)
static int
apply$mcIDD$sp(double v1, double v2)
static int
apply$mcIDI$sp(double v1, int v2)
static int
apply$mcIDJ$sp(double v1, long v2)
static int
apply$mcIID$sp(int v1, double v2)
static int
apply$mcIII$sp(int v1, int v2)
static int
apply$mcIIJ$sp(int v1, long v2)
static int
apply$mcIJD$sp(long v1, double v2)
static int
apply$mcIJI$sp(long v1, int v2)
static int
apply$mcIJJ$sp(long v1, long v2)
static long
apply$mcJDD$sp(double v1, double v2)
static long
apply$mcJDI$sp(double v1, int v2)
static long
apply$mcJDJ$sp(double v1, long v2)
static long
apply$mcJID$sp(int v1, double v2)
static long
apply$mcJII$sp(int v1, int v2)
static long
apply$mcJIJ$sp(int v1, long v2)
static long
apply$mcJJD$sp(long v1, double v2)
static long
apply$mcJJI$sp(long v1, int v2)
static long
apply$mcJJJ$sp(long v1, long v2)
static void
apply$mcVDD$sp(double v1, double v2)
static void
apply$mcVDI$sp(double v1, int v2)
static void
apply$mcVDJ$sp(double v1, long v2)
static void
apply$mcVID$sp(int v1, double v2)
static void
apply$mcVII$sp(int v1, int v2)
static void
apply$mcVIJ$sp(int v1, long v2)
static void
apply$mcVJD$sp(long v1, double v2)
static void
apply$mcVJI$sp(long v1, int v2)
static void
apply$mcVJJ$sp(long v1, long v2)
static boolean
apply$mcZDD$sp(double v1, double v2)
static boolean
apply$mcZDI$sp(double v1, int v2)
static boolean
apply$mcZDJ$sp(double v1, long v2)
static boolean
apply$mcZID$sp(int v1, double v2)
static boolean
apply$mcZII$sp(int v1, int v2)
static boolean
apply$mcZIJ$sp(int v1, long v2)
static boolean
apply$mcZJD$sp(long v1, double v2)
static boolean
apply$mcZJI$sp(long v1, int v2)
static boolean
apply$mcZJJ$sp(long v1, long v2)
boolean
canEqual(java.lang.Object x$1)
ClusterRouterPool
copy(Pool local, ClusterRouterPoolSettings settings)
Pool
copy$default$1()
ClusterRouterPoolSettings
copy$default$2()
RouterActor
createRouterActor()
INTERNAL APIboolean
equals(java.lang.Object x$1)
int
hashCode()
Pool
local()
Routee
newRoutee(Props routeeProps, ActorContext context)
INTERNAL APIint
nrOfInstances(ActorSystem sys)
Initial number of routee instancesint
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
scala.Option<Resizer>
resizer()
Pool with dynamically resizable number of routees return theResizer
to use.ClusterRouterPoolSettings
settings()
SupervisorStrategy
supervisorStrategy()
SupervisorStrategy for the head actor, i.e.java.lang.String
toString()
static scala.Option<scala.Tuple2<Pool,ClusterRouterPoolSettings>>
unapply(ClusterRouterPool x$0)
RouterConfig
withFallback(RouterConfig other)
Overridable merge strategy, by default completely prefersthis
(i.e.-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface akka.cluster.routing.ClusterRouterConfigBase
createRouter, isManagementMessage, routerDispatcher, routingLogicController, stopRouterWhenAllRouteesRemoved, super$isManagementMessage
-
Methods inherited from interface akka.routing.Pool
enrichWithPoolDispatcher, props, stopRouterWhenAllRouteesRemoved, usePoolDispatcher
-
Methods inherited from interface akka.routing.RouterConfig
verifyConfig
-
-
-
-
Constructor Detail
-
ClusterRouterPool
public ClusterRouterPool(Pool local, ClusterRouterPoolSettings settings)
-
-
Method Detail
-
apply
public static ClusterRouterPool apply(Pool local, ClusterRouterPoolSettings settings)
-
unapply
public static scala.Option<scala.Tuple2<Pool,ClusterRouterPoolSettings>> unapply(ClusterRouterPool x$0)
-
apply$mcZDD$sp
public static boolean apply$mcZDD$sp(double v1, double v2)
-
apply$mcDDD$sp
public static double apply$mcDDD$sp(double v1, double v2)
-
apply$mcFDD$sp
public static float apply$mcFDD$sp(double v1, double v2)
-
apply$mcIDD$sp
public static int apply$mcIDD$sp(double v1, double v2)
-
apply$mcJDD$sp
public static long apply$mcJDD$sp(double v1, double v2)
-
apply$mcVDD$sp
public static void apply$mcVDD$sp(double v1, double v2)
-
apply$mcZDI$sp
public static boolean apply$mcZDI$sp(double v1, int v2)
-
apply$mcDDI$sp
public static double apply$mcDDI$sp(double v1, int v2)
-
apply$mcFDI$sp
public static float apply$mcFDI$sp(double v1, int v2)
-
apply$mcIDI$sp
public static int apply$mcIDI$sp(double v1, int v2)
-
apply$mcJDI$sp
public static long apply$mcJDI$sp(double v1, int v2)
-
apply$mcVDI$sp
public static void apply$mcVDI$sp(double v1, int v2)
-
apply$mcZDJ$sp
public static boolean apply$mcZDJ$sp(double v1, long v2)
-
apply$mcDDJ$sp
public static double apply$mcDDJ$sp(double v1, long v2)
-
apply$mcFDJ$sp
public static float apply$mcFDJ$sp(double v1, long v2)
-
apply$mcIDJ$sp
public static int apply$mcIDJ$sp(double v1, long v2)
-
apply$mcJDJ$sp
public static long apply$mcJDJ$sp(double v1, long v2)
-
apply$mcVDJ$sp
public static void apply$mcVDJ$sp(double v1, long v2)
-
apply$mcZID$sp
public static boolean apply$mcZID$sp(int v1, double v2)
-
apply$mcDID$sp
public static double apply$mcDID$sp(int v1, double v2)
-
apply$mcFID$sp
public static float apply$mcFID$sp(int v1, double v2)
-
apply$mcIID$sp
public static int apply$mcIID$sp(int v1, double v2)
-
apply$mcJID$sp
public static long apply$mcJID$sp(int v1, double v2)
-
apply$mcVID$sp
public static void apply$mcVID$sp(int v1, double v2)
-
apply$mcZII$sp
public static boolean apply$mcZII$sp(int v1, int v2)
-
apply$mcDII$sp
public static double apply$mcDII$sp(int v1, int v2)
-
apply$mcFII$sp
public static float apply$mcFII$sp(int v1, int v2)
-
apply$mcIII$sp
public static int apply$mcIII$sp(int v1, int v2)
-
apply$mcJII$sp
public static long apply$mcJII$sp(int v1, int v2)
-
apply$mcVII$sp
public static void apply$mcVII$sp(int v1, int v2)
-
apply$mcZIJ$sp
public static boolean apply$mcZIJ$sp(int v1, long v2)
-
apply$mcDIJ$sp
public static double apply$mcDIJ$sp(int v1, long v2)
-
apply$mcFIJ$sp
public static float apply$mcFIJ$sp(int v1, long v2)
-
apply$mcIIJ$sp
public static int apply$mcIIJ$sp(int v1, long v2)
-
apply$mcJIJ$sp
public static long apply$mcJIJ$sp(int v1, long v2)
-
apply$mcVIJ$sp
public static void apply$mcVIJ$sp(int v1, long v2)
-
apply$mcZJD$sp
public static boolean apply$mcZJD$sp(long v1, double v2)
-
apply$mcDJD$sp
public static double apply$mcDJD$sp(long v1, double v2)
-
apply$mcFJD$sp
public static float apply$mcFJD$sp(long v1, double v2)
-
apply$mcIJD$sp
public static int apply$mcIJD$sp(long v1, double v2)
-
apply$mcJJD$sp
public static long apply$mcJJD$sp(long v1, double v2)
-
apply$mcVJD$sp
public static void apply$mcVJD$sp(long v1, double v2)
-
apply$mcZJI$sp
public static boolean apply$mcZJI$sp(long v1, int v2)
-
apply$mcDJI$sp
public static double apply$mcDJI$sp(long v1, int v2)
-
apply$mcFJI$sp
public static float apply$mcFJI$sp(long v1, int v2)
-
apply$mcIJI$sp
public static int apply$mcIJI$sp(long v1, int v2)
-
apply$mcJJI$sp
public static long apply$mcJJI$sp(long v1, int v2)
-
apply$mcVJI$sp
public static void apply$mcVJI$sp(long v1, int v2)
-
apply$mcZJJ$sp
public static boolean apply$mcZJJ$sp(long v1, long v2)
-
apply$mcDJJ$sp
public static double apply$mcDJJ$sp(long v1, long v2)
-
apply$mcFJJ$sp
public static float apply$mcFJJ$sp(long v1, long v2)
-
apply$mcIJJ$sp
public static int apply$mcIJJ$sp(long v1, long v2)
-
apply$mcJJJ$sp
public static long apply$mcJJJ$sp(long v1, long v2)
-
apply$mcVJJ$sp
public static void apply$mcVJJ$sp(long v1, long v2)
-
local
public Pool local()
- Specified by:
local
in interfaceClusterRouterConfigBase
-
settings
public ClusterRouterPoolSettings settings()
- Specified by:
settings
in interfaceClusterRouterConfigBase
-
newRoutee
public Routee newRoutee(Props routeeProps, ActorContext context)
INTERNAL API
-
nrOfInstances
public int nrOfInstances(ActorSystem sys)
Initial number of routee instances- Specified by:
nrOfInstances
in interfacePool
- Parameters:
sys
- (undocumented)- Returns:
- (undocumented)
-
resizer
public scala.Option<Resizer> resizer()
Description copied from interface:Pool
Pool with dynamically resizable number of routees return theResizer
to use. The resizer is invoked once when the router is created, before any messages can be sent to it. Resize is also triggered when messages are sent to the routees, and the resizer is invoked asynchronously, i.e. not necessarily before the message has been sent.
-
createRouterActor
public RouterActor createRouterActor()
INTERNAL API- Specified by:
createRouterActor
in interfacePool
- Specified by:
createRouterActor
in interfaceRouterConfig
- Returns:
- (undocumented)
-
supervisorStrategy
public SupervisorStrategy supervisorStrategy()
Description copied from interface:Pool
SupervisorStrategy for the head actor, i.e. for supervising the routees of the pool.- Specified by:
supervisorStrategy
in interfacePool
- Returns:
- (undocumented)
-
withFallback
public RouterConfig withFallback(RouterConfig other)
Description copied from interface:RouterConfig
Overridable merge strategy, by default completely prefersthis
(i.e. no merge).- Specified by:
withFallback
in interfaceRouterConfig
- Parameters:
other
- (undocumented)- Returns:
- (undocumented)
-
copy
public ClusterRouterPool copy(Pool local, ClusterRouterPoolSettings settings)
-
copy$default$1
public Pool copy$default$1()
-
copy$default$2
public ClusterRouterPoolSettings copy$default$2()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-