1

渡される多くのメッセージを処理するAkka ActorEventBus（参照https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/event/EventBus.scala#L70 ）がありますさまざまな俳優の周り。

このバスを購読するアクターを設定しました：

/**
   * special actor that transports messages to the hive
   */
  val hiveTalk = {
    val subscriber = actorSystem.actorOf(Props(new HiveTransport))

    Bus.subscribe( subscriber, "/app/browser/" )
    Bus.subscribe( subscriber, "/app/mobile/" )
  }

のMessageBus実装であるクラスはActorEventBus次のようになります。

/**
 * message bus to route messages to their appropriate contexts
 */
class MessageBus extends ActorEventBus with LookupClassification {

    type Event = MessageEvent
  type Classifier = String

  protected def mapSize(): Int = {
    10
  }

  protected def classify(event: Event): Classifier = {
    event.channel
  }

  protected def publish(event: Event, subscriber: Subscriber): Unit = {
    subscriber ! event
  }

}

問題

何らかの理由で、サブチャネルに送信されたように見えるメッセージがアクターサブスクライバー/app/browser/26によって受信されていません。hiveTalk

なぜ何かアイデアはありますか？

4

1 に答える 1

2

解決しました。どうやらLookup Classification、実際には単純な単一チャネルの実装のみを意図しているようです。

Subchannel Classificationは、実際にサブチャネルを実装することを目的としたAkkaの特性です。

http://doc.akka.io/docs/akka/2.0/scala/event-bus.html#Subchannel_Classification

于 2012-09-24T23:48:04.480 に答える