क्या अक्का इवेंटबस रिमोट एक्टर्स के साथ काम करता है?

Question

क्या अक्का का इवेंटबस रिमोट एक्टर्स के साथ काम करता है?

जहां तक ​​मैं कह सकता हूं, यह मूल रूप से इसका समर्थन नहीं करता है। क्या कोई कृपया पुष्टि कर सकता है?

ऐसा लगता है कि कुछ अभिनेताओं को कोड करना संभव होगा जो समान कार्यक्षमता प्रदान करते हैं। जैसे एक दूरस्थ अभिनेता शुरू करें जो रिमोट सर्वर पर इवेंटबस की सदस्यता लेता है, और स्थानीय इवेंटबस पर पुन: प्रकाशित करने के लिए संदेशों को स्थानीय अभिनेता को वापस भेजता है। लेकिन यह कोई मुद्दा नहीं है, अगर यह पहले से ही समर्थित है!

धन्यवाद

Answer 1

EventBus ही स्थानीय है, जिसका अर्थ है कि घटनाओं स्वचालित रूप से अन्य सिस्टम पर EventBuses को हस्तांतरित नहीं कर रहे हैं, लेकिन आप किसी भी ActorRef आप रिमोट भी शामिल होते हैं चाहते हैं, सदस्यता ले सकते हैं।

case class Subscribe(clazz: Class[_]) 
system.actorOf(Props(new Actor { 
    def receive = { 
    case Subscribe(c) => 
     context.system.eventStream.subscribe(sender, c) 
    } 
}), "eventer") 

तो फिर तुम दूरस्थ मेजबान से देख सकते हैं कि एक और अपने आप सदस्यता ली है: आप केवल नोड पर एक अभिनेता जहां घटनाओं उत्पन्न कर रहे हैं की जरूरत है।