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
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Router, B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
- def ensuring(cond: (Router) ⇒ Boolean, msg: ⇒ Any): Router
- def ensuring(cond: (Router) ⇒ Boolean): Router
- def ensuring(cond: Boolean, msg: ⇒ Any): Router
- def ensuring(cond: Boolean): Router
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val logic: RoutingLogic
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
withRoutees(rs: IndexedSeq[Routee]): Router
Create a new instance with the specified routees and the same RoutingLogic.
- def →[B](y: B): (Router, B)