akka

7Ciepło

1Odpowiedz

Akka: komunikowanie się z powrotem poza systemem aktora?

Mam następujący sterownik/główne klasy zamykającą mój program Akka: // Groovy pseudo-code class FizzBuzz { ActorSystem actorSystem static void main(String[] args) { FizzBuzz d = new

7Ciepło

2Odpowiedz

Jak odwołać się do standardowego ActorSystem struktury gry 2?

Chciałbym użyć programu planującego z Akka, przykłady mówią: system.scheduler.scheduleOnce() ale nie ma prawdziwej informacji, gdzie „system” powinno pochodzić. Dokumentacja jest trochę powierzchown

5Ciepło

1Odpowiedz

Czy istnieje sposób na uzyskanie przewidywalnego nazewnictwa aktorów za pomocą Akka-Stream?

Używam ActorPublisher jako Akka-Stream Source. Nie wiem, jak przewidzieć nazwę aktora wejściowego, aby móc wysyłać wiadomości z innych części aplikacji. Mam instancji moje źródło tak: val src = Source

7Ciepło

1Odpowiedz

Kiedy używać Akka Microkernel?

Czytam dokumentację Akka i jestem ciekaw czegoś, co naprawdę nie jest tak dobrze wyjaśnione. One mention coś o nazwie Akka Microkernel i wskazują, że jego rodzaj app bootstrapper/launcher, ale tak nap

5Ciepło

1Odpowiedz

Konfiguracja Typesafe: Załaduj konfigurację z src/test/resources

To jest pytanie dla początkujących. Więc moja aplikacja struktura wygląda src/main/java/... src/main/resources/application.conf src/test/java/... src/test/resources/module/test.module.conf appli

5Ciepło

1Odpowiedz

Howto ponownie wysłać wiadomość po aktor jest ponownie uruchomiony przez strategię nadzoru

Mam rodzica aktora (A) z dwoma dziećmi aktorów (B). Stworzyłem strategię nadzoru w A, więc w przypadku wyjątku w B, B zostanie zrestartowane. Jak ponownie wysłać wiadomość, która spowodowała wyjątek z

5Ciepło

1Odpowiedz

MDC (odwzorowany kontekst diagnostyczny) Logowanie w AKKA

Chcę zaimplementować logowanie loginu MDC na mojej aplikacji AKKA w celu zorganizowania i posiadania bardziej infomatywnego dziennika; jednak przeczytałem również, że MDC może nie działać dobrze z AKK

5Ciepło

1Odpowiedz

Howto stworzyć obserwatora, takiego jak komunikacja pomiędzy aktorami z Akka

W klasycznym programowaniu używam wzorca obeserver na wypadek, gdy chcę powiadomić obserwatorów o zmianach. Jaki jest ekwiwalentny wzór w Akce? przypadków użycia: Aktor (PropertyServiceActor) czyta i

8Ciepło

1Odpowiedz

Jak przetestować aktora Akka, który wysyła wiadomość do innego aktora?

Używam ScalaTest z Akka TestKit do pisania testów jednostkowych i integracyjnych dla aktora, którego kodowałem, aby po prostu wysłać wiadomość do innego aktora bez mutowania żadnego stanu wewnętrznego

7Ciepło

1Odpowiedz

Akka-http strumieniowe za pomocą Slick 3,0 Databasepublisher

Używam zręczny 3.0 i posiada databasepublisher obiekt jako def getAsStream = db.stream[Entity](tblquery.result) używam Akka-http dla warstwy spoczynku następująco, val route = path("stream"){ get