アッカ：Subscriberは

Question

パブリッククラス加入者がUntypedActor {

public Subscriber() { 
    ActorRef mediator = 
      DistributedPubSub.get(getContext().system()).mediator(); 
    // subscribe to the topic named "content" 
    mediator.tell(new DistributedPubSubMediator.Subscribe("content", getSelf()), 
      getSelf()); 
    mediator.tell(new DistributedPubSubMediator.Subscribe("content_2", getSelf()), 
      getSelf()); 
} 

public void onReceive(Object msg) { 
    if (msg instanceof String) 
     System.out.println("Message received: " + msg); 
    else if (msg instanceof DistributedPubSubMediator.SubscribeAck) 
     System.out.println("subscribing"); 
    else 
     unhandled(msg); 
} 

}

を拡張する複数のトピックを扱う今トピックが同じ構造体名（例えばFOO）を有するが、異なるタイプの両方と仮定する。この場合、サブスクライバはどのトピックから "foo"メッセージを受信したかを知ることができますか？

Answer 1

したがって、DistributedPubSub（DPS）は、アクターにメッセージを取得する手段に過ぎません。 receiveループは、メッセージがtell、ask、またはDPS経由で送信されても​​、メッセージがその受信トレイにあることを知っているだけで気にしません。 DPSは受信したメッセージに対してforward（）を呼び出すので、DPSにメッセージを公開した人の送信者情報は書き換えられません。あなたの質問に対する答えは、それがどんなDPSに入ってきたのか分からないことです。それが問題であれば、おそらくデザインに何か問題があると思います。元のメッセージの送信者やメッセージ自体の実際のタイプではなく、それが重要である妥当な理由を考えることはできません。だから私は私の切り替えとタイプをチェックし、もしActorRefのパスから来た場所を知る必要があれば、それを行います。