final case class Router(logic: RoutingLogic, routees: IndexedSeq[Routee] = Vector.empty) extends Product with Serializable
For each message that is sent through the router via the #route method the
RoutingLogic decides to which Routee to send the message. The Routee itself
knows how to perform the actual sending. Normally the RoutingLogic picks one of the
contained routees
, but that is up to the implementation of the RoutingLogic.
A Router
is immutable and the RoutingLogic must be thread safe.
- Source
- Router.scala
- Alphabetic
- By Inheritance
- Router
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
Router(logic: RoutingLogic, routees: Iterable[Routee])
Java API
-
new
Router(logic: RoutingLogic)
Java API
- new Router(logic: RoutingLogic, routees: IndexedSeq[Routee] = Vector.empty)
Value Members
-
def
addRoutee(sel: ActorSelection): Router
Create a new instance with one more ActorSelectionRoutee for the specified akka.actor.ActorSelection and the same RoutingLogic.
-
def
addRoutee(ref: ActorRef): Router
Create a new instance with one more ActorRefRoutee for the specified akka.actor.ActorRef and the same RoutingLogic.
-
def
addRoutee(routee: Routee): Router
Create a new instance with one more routee and the same RoutingLogic.
- val logic: RoutingLogic
-
def
removeRoutee(sel: ActorSelection): Router
Create a new instance without the ActorSelectionRoutee for the specified akka.actor.ActorSelection.
-
def
removeRoutee(ref: ActorRef): Router
Create a new instance without the ActorRefRoutee for the specified akka.actor.ActorRef.
-
def
removeRoutee(routee: Routee): Router
Create a new instance without the specified routee.
-
def
route(message: Any, sender: ActorRef): Unit
Send the message to the destination Routee selected by the RoutingLogic.
Send the message to the destination Routee selected by the RoutingLogic. If the message is a akka.routing.RouterEnvelope it will be unwrapped before sent to the destinations. Messages wrapped in a Broadcast envelope are always sent to all
routees
. - val routees: IndexedSeq[Routee]
-
def
withRoutees(rs: IndexedSeq[Routee]): Router
Create a new instance with the specified routees and the same RoutingLogic.