Java için Akka EventBus örneği

Question

Java'da Akka tarafından sağlanan EventBus'un (Scala!) Nasıl kullanıldığını öğrenmek için bazı önerilerde bulunun. Web sitesinde belgelerine eksik gibi görünüyor: http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html

Bildiğim kadarıyla, aktör gibi belirli iletileri tepki oluşturulmalıdır anlaşılan olarak:

final ActorSystem actorSystem = ActorSystem.create("ServerEvents"); 
final ActorRef actor = actorSystem.actorOf(new Props(SeverEventHandler.class)); 
actorSystem.eventStream().subscribe(actor,ServerMessage.class); 

Ama şimdi bir mesaj göndermek için nasıl net değil olay otobüsü.

Birisi lütfen bazı iyi öğreticiler/örnekler/etc paylaşabilirsiniz?

Answer 1

Sana kısaca sadece bir satır olduğunu düşünüyorum:

final ActorSystem actorSystem = ActorSystem.create("ServerEvents"); 
final ActorRef actor = actorSystem.actorOf(new Props(SeverEventHandler.class)); 
actorSystem.eventStream().subscribe(actor,ServerMessage.class); 

actorSystem.eventStream().publish(new ServerMessage()); <<== add this 

ServerEventHandler olması gerekirken ben bu arada çalışmasında API içinde, docs geliştirmek için bir bilet açtı

public class ServerEventHandler extends UntypedActor { 
    @Override 
    public void onReceive(final Object message) { 
    System.out.println("Got event in thread: " + Thread.currentThread().getName()); 
    System.out.println("Event: " + message); 
    } 
}