Package akka.routing

Class Router

java.lang.Object

akka.routing.Router

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product, scala.Serializable

public final class Router
extends java.lang.Object
implements scala.Product, scala.Serializable

Java API

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
Router(RoutingLogic logic)
Router(RoutingLogic logic, java.lang.Iterable<Routee> routees)	Java API
Router(RoutingLogic logic, scala.collection.immutable.IndexedSeq<Routee> routees)

Method Summary

Modifier and Type	Method	Description
static scala.collection.immutable.IndexedSeq<Routee>	$lessinit$greater$default$2()
Router	addRoutee(ActorRef ref)	Create a new instance with one more ActorRefRoutee for the specified ActorRef and the same RoutingLogic.
Router	addRoutee(ActorSelection sel)	Create a new instance with one more ActorSelectionRoutee for the specified ActorSelection and the same RoutingLogic.
Router	addRoutee(Routee routee)	Create a new instance with one more routee and the same RoutingLogic.
static Router	apply(RoutingLogic logic, scala.collection.immutable.IndexedSeq<Routee> routees)
static scala.collection.immutable.IndexedSeq<Routee>	apply$default$2()
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)
Router	copy(RoutingLogic logic, scala.collection.immutable.IndexedSeq<Routee> routees)
RoutingLogic	copy$default$1()
scala.collection.immutable.IndexedSeq<Routee>	copy$default$2()
boolean	equals(java.lang.Object x$1)
int	hashCode()
RoutingLogic	logic()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
Router	removeRoutee(ActorRef ref)	Create a new instance without the ActorRefRoutee for the specified ActorRef.
Router	removeRoutee(ActorSelection sel)	Create a new instance without the ActorSelectionRoutee for the specified ActorSelection.
Router	removeRoutee(Routee routee)	Create a new instance without the specified routee.
void	route(java.lang.Object message, ActorRef sender)	Send the message to the destination Routee selected by the RoutingLogic.
scala.collection.immutable.IndexedSeq<Routee>	routees()
java.lang.String	toString()
static scala.Option<scala.Tuple2<RoutingLogic,scala.collection.immutable.IndexedSeq<Routee>>>	unapply(Router x$0)
Router	withRoutees(scala.collection.immutable.IndexedSeq<Routee> rs)	Create a new instance with the specified routees and the same RoutingLogic.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Router

public Router(RoutingLogic logic,
              scala.collection.immutable.IndexedSeq<Routee> routees)

Router

public Router(RoutingLogic logic)

Router

public Router(RoutingLogic logic,
              java.lang.Iterable<Routee> routees)

Java API

Parameters:

logic - (undocumented)

routees - (undocumented)

Method Detail

$lessinit$greater$default$2

public static scala.collection.immutable.IndexedSeq<Routee> $lessinit$greater$default$2()

apply

public static Router apply(RoutingLogic logic,
                           scala.collection.immutable.IndexedSeq<Routee> routees)

apply$default$2

public static scala.collection.immutable.IndexedSeq<Routee> apply$default$2()

unapply

public static scala.Option<scala.Tuple2<RoutingLogic,scala.collection.immutable.IndexedSeq<Routee>>> unapply(Router 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)

logic

public RoutingLogic logic()

routees

public scala.collection.immutable.IndexedSeq<Routee> routees()

route

public void route(java.lang.Object message,
                  ActorRef sender)

Send the message to the destination Routee selected by the RoutingLogic. If the message is a RouterEnvelope it will be unwrapped before sent to the destinations. Messages wrapped in a Broadcast envelope are always sent to all routees.

Parameters:

message - (undocumented)

sender - (undocumented)

withRoutees

public Router withRoutees(scala.collection.immutable.IndexedSeq<Routee> rs)

Create a new instance with the specified routees and the same RoutingLogic.

Parameters:

rs - (undocumented)

Returns:

(undocumented)

addRoutee

public Router addRoutee(Routee routee)

Create a new instance with one more routee and the same RoutingLogic.

Parameters:

routee - (undocumented)

Returns:

(undocumented)

addRoutee

public Router addRoutee(ActorRef ref)

Create a new instance with one more ActorRefRoutee for the specified ActorRef and the same RoutingLogic.

Parameters:

ref - (undocumented)

Returns:

(undocumented)

addRoutee

public Router addRoutee(ActorSelection sel)

Create a new instance with one more ActorSelectionRoutee for the specified ActorSelection and the same RoutingLogic.

Parameters:

sel - (undocumented)

Returns:

(undocumented)

removeRoutee

public Router removeRoutee(Routee routee)

Create a new instance without the specified routee.

Parameters:

routee - (undocumented)

Returns:

(undocumented)

removeRoutee

public Router removeRoutee(ActorRef ref)

Create a new instance without the ActorRefRoutee for the specified ActorRef.

Parameters:

ref - (undocumented)

Returns:

(undocumented)

removeRoutee

public Router removeRoutee(ActorSelection sel)

Create a new instance without the ActorSelectionRoutee for the specified ActorSelection.

Parameters:

sel - (undocumented)

Returns:

(undocumented)

copy

public Router copy(RoutingLogic logic,
                   scala.collection.immutable.IndexedSeq<Routee> routees)

copy$default$1

public RoutingLogic copy$default$1()

copy$default$2

public scala.collection.immutable.IndexedSeq<Routee> copy$default$2()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object