Составление поведения признаков в Scala в методе приема Akka

Ответ 1

Вы можете использовать super[T] для ссылки на элементы определенных суперклассов/признаков.

Например:

trait IntActor extends Actor {
    def receive = {
        case i: Int => println("Int!")
    }
}

trait StringActor extends Actor {
    def receive = {
        case s: String => println("String!")
    }
}

class IntOrString extends Actor with IntActor with StringActor {
    override def receive = super[IntActor].receive orElse super[StringActor].receive
}

val a = actorOf[IntOrString].start
a ! 5 //prints Int!
a ! "Hello" //prints String!

Edit:

В ответ на комментарий Hugo, вот решение, которое позволяет вам составлять микшины без необходимости вручную подключать их вместе. По сути, он включает базовый признак с изменяемым List[Receive], и каждый смешанный признак вызывает метод для добавления своего собственного приема в список.

trait ComposableActor extends Actor {
  private var receives: List[Receive] = List()
  protected def registerReceive(receive: Receive) {
    receives = receive :: receives
  }

  def receive = receives reduce {_ orElse _}
}

trait IntActor extends ComposableActor {
  registerReceive {
    case i: Int => println("Int!")
  }
}

trait StringActor extends ComposableActor {
  registerReceive {
    case s: String => println("String!")
  }
}

val a = actorOf(new ComposableActor with IntActor with StringActor).start
a ! 5 //prints Int!
a ! "test" //prints String!

Единственное, о чем нужно помнить, это то, что порядок получения не должен быть важен, поскольку вы не сможете легко предсказать, какой из них является первым в цепочке, хотя вы можете решить это, используя изменяемый хэш файл вместо списка.

Ответ 2

Вы можете использовать пустой прием в базовом классе актера, и цепочка получает в своих определениях. Образец для Akka 2.0-M2:

import akka.actor.Actor
import akka.actor.Props
import akka.event.Logging
import akka.actor.ActorSystem

class Logger extends Actor {
  val log = Logging(context.system, this)

  override def receive = new Receive {
    def apply(any: Any) = {}
    def isDefinedAt(any: Any) = false
  }
}

trait Errors extends Logger {
  override def receive = super.receive orElse {
    case "error" => log.info("received error")
  }
}

trait Warns extends Logger {
  override def receive = super.receive orElse {
    case "warn" => log.info("received warn")
  }
}

object Main extends App {
  val system = ActorSystem("mysystem")
  val actor = system.actorOf(Props(new Logger with Errors with Warns), name = "logger")
  actor ! "error"
  actor ! "warn"
}