Akka (java), transmisja nieblokująca dla wszystkich dzieci
Powiedzmy, że mam Aktora Regionu, a każdy region ma w sobie pewną liczbę osób. Jak przekazujesz wiadomość wszystkim, wiedząc, że lista osób może się zmieniać w czasie, routery rozgłoszeniowe wydają się być wyborem, ale problem polega na tym, że mają one maksymalną liczbę tras i że nie mogę dynamicznie dołączać ludzi do router.
Moje pytanie brzmi: wiem, że istnieje EventBus, mógłbym subskrybować moich ludzi na Bus, ale nie chcę, aby otrzymywali każdą wysłaną wiadomość, chcę, aby otrzymali wiadomości z regionu.
teraz akka, musimy utworzyć router z pewną liczbą rut, na przykład:
Router router = new router(person1, person2)
to źle, ponieważ na początku nie ma nikogo w regionie, nie znam ludzi, którzy dołączą do mojego regionu.
czy istnieje sposób na stworzenie dynamicznego routera: przykład:
Region region = new region()
region.router = new Router()
Person person1 = new Person()
region.router.subscribe(person1);
region.router.tell("hello",null);