जावा

Question

के लिए अक्का इवेंटबस का उदाहरण जावा में अक्का द्वारा प्रदान की गई इवेंटबस का उपयोग करने के बारे में कुछ सलाह चाहिए (स्कैला नहीं!)। वेबसाइट पर प्रलेखन अधूरा लगता है: http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html

जहां तक ​​मैं समझ गया, अभिनेता की तरह, विशिष्ट संदेशों पर प्रतिक्रिया करने के लिए बनाया जाना चाहिए:

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

लेकिन अब यह स्पष्ट नहीं है कि करने के लिए एक संदेश भेजने के लिए घटना बस

क्या कोई कृपया कुछ अच्छे ट्यूटोरियल/उदाहरण/आदि साझा कर सकता है?

Answer 1

मुझे लगता है कि आप सिर्फ एक लाइन कम कर रहे हैं:

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 होना चाहिए जबकि तरह

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); 
    } 
}