messageClasses

#Actor.messageClasses

Actor.messageClasses is a sequence of all the message classes, Class[_ <: AnyRef], bound by either the bind or bindSafe functions. This can be helpful when working with large composites.

Test.

case class Set(value: Int)
case class Get()
case class Times2()

class SaverComponentFactory extends ComponentFactory {
  override def instantiate(actor: Actor) = new SaverComponent(actor)
}

class SaverComponent(actor: Actor) extends Component(actor) {
  var i = 0

  bind(classOf[Set], setFunc)
  private def setFunc(msg: AnyRef, rf: Any => Unit) {
    i = msg.asInstanceOf[Set].value
    rf(null)
  }

  bind(classOf[Get], getFunc)
  private def getFunc(msg: AnyRef, rf: Any => Unit) {rf(i)}
}

class DoubleComponentFactory extends ComponentFactory {
  addDependency(classOf[SaverComponentFactory])
  override def instantiate(actor: Actor) = new DoubleComponent(actor)
}

class DoubleComponent(actor: Actor) extends Component(actor) {
  val saver = actor.component(classOf[SaverComponentFactory]).asInstanceOf[SaverComponent]
  bind(classOf[Times2], doubleFunc)
  private def doubleFunc(msg: AnyRef, rf: Any => Unit) {
    saver.i *= 2
    rf(null)
  }
}

class DoubleFactory extends Factory(null) {
  include(new DoubleComponentFactory)
}

val doubleFactory = new DoubleFactory
val double = doubleFactory.newActor(new ReactorMailbox)
val messageClasses = double.messageClasses
Future(messageClasses, Loop((key: Class[_ <: AnyRef], value: Class[_ <: AnyRef]) => println(value)))

Output.

class org.agilewiki.blip.seq.messageClasses.Get
class org.agilewiki.blip.seq.messageClasses.Set
class org.agilewiki.blip.seq.messageClasses.Times2

MessageClassesTest

Tutorial