I need to create a stage with one inlet accepting elements of type
Message and three outlets emitting elements of types A, B, C, all of which
are Message subtypes.
Depending on which element came (A, B or C) it should be emitted on one of
three outlets.
I am wondering how is it possible to achieve? If I create a State with
DemandFromAny(all three outlets), I have no guarantee that element passed
in State's onInput is an instance of type that demanding outlets should
emit.
Here is FlexiRoute example (I simplified it to Message, A, B and C types to
make in my app-context independent). It works only when it is so lucky that
element matches type of the demanding outlet.
sealed trait Message
class A extends Message
class B extends Message
class C extends Message
class MessageDiscriminatorShape(_init: Init[Message] =
Name[Message]("MessageDiscriminator"))
extends FanOutShape[Message](_init) {
val outA = newOutlet[A]("outA")
val outB = newOutlet[B]("outB")
val outC = newOutlet[C]("outC")
protected override def construct(i: Init[Message]) = new
MessageDiscriminatorShape(i)
}
class MessageDiscriminator
extends FlexiRoute[Message, MessageDiscriminatorShape](
new MessageDiscriminatorShape,
OperationAttributes.name("MessageDiscriminator")) {
import FlexiRoute._
override def createRouteLogic(p: PortT) = new RouteLogic[Message] {
override def initialState = State[Any](DemandFromAny(p.outlets)) {
(ctx, _, element) =>
element match {
case e: A =>
ctx.emit(p.outA)(e)
case e: B =>
ctx.emit(p.outB)(e)
case e: C =>
ctx.emit(p.outC)(e)
}
SameState
}
override def initialCompletionHandling = eagerClose
}
}
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
