Tag: akka

Gibt es Akka (Java-API) Akteure (UntypeActor) und die Nachrichten in der Anwendung. Laut API-Vertrag für den Fall vor ein paar Botschaften richten sich an die gleichen Schauspieler, Sie sind in der Warteschlange und verarbeitet mit one-by-one. Ich

Arbeite ich an akka Akteure(JAVA) und kam vor kurzem zu wissen, dass es gibt 3 Möglichkeiten(können auch mehr sein) zu wissen, vorhandenen ein Schauspieler. Senden eine Identifizieren-Nachricht: ActorSelection sel = actorSystem.actorSelection("akka://test/user/TestActor"); AskableActorSelection asker = new AskableActorSelection(sel); Future<Object>

Kann ich nicht erstellen, ein Schauspieler aus irgendeinem Grund (hier ist eine einfache version von meinem Klassen-Hierarchie): abstract class Class1[T <: Class2[_]: ClassTag] extends Actor { //.... val res = List(1, 2, 3) map { x =>

mit Akka 2.0, die versuchen, eine Nachricht zu senden, um selbst (unter Verwendung der ask-Muster) import akka.pattern.ask import scala.concurrent.{Await, Future} import akka.actor.{Props, Actor, ActorSystem} import scala.concurrent.duration._ import akka.util.Timeout object askTest extends App{ implicit val timeout = Timeout(5

Eines der Merkmale von Akka HTTP (formal bekannt als Spray) ist seine Fähigkeit, automatisch marshal und unmarshal-Daten hin und her von json in das case-Klassen, etc. Ich habe den Erfolg bekommen, das gut funktioniert. Im moment bin

Ich würde gern ein Akka Schauspieler mit dem Klassennamen, wie gezeigt. Ich habe versucht, viele Variationen des Systems.actorOf(neue Requisiten(theProcessor.getClass), name = "Test"), aber ich kann nicht ankommen dieses zu wirken. Jede Idee, erstellen einen Schauspieler von der

Ich bin erstellen Akteure in java mit akka-Bibliothek zu implementieren, das Akkord-system. Mein Ziel hier ist es, zwei Schauspieler die sich gegenseitig Nachrichten schicken. Aber wenn ich das tun bekomme ich folgende Fehlermeldung : [INFO] [12/24/2015 15:27:33.521]

MyService.scala:33: could not find implicit value for parameter eh: spray.routing.ExceptionHandler Ich habe laufen in eine "fehlende implizite" Kompilierungs-Fehler mit Hilfe von Akka, in spray.io-code, der eine http-Aufruf einen separaten back-end-server, die als Teil der Reaktion auf einen

Habe ich ein Schauspieler, der anrufweitergabe an eine stateful singleton. Der singleton ist stateful, da es die Aufrechterhaltung eines map von Objekten. Dieses singleton-Objekt wird verwendet, nur in die Schauspieler und in einer Klasse (nicht Schauspieler), wo

Hallo, ich bin neu auf akka und m versuchen zu entwickeln, Probe akka Anwendung aber wenn ich execute-Befehl ausführen auf der shell gibt es mir Ungelöste Abhängigkeiten Warnungen und zeigt dann Fehler hier ist mein Main.scala-Datei import

Ich habe eine sehr einfache Struktur auf Basis von Akka actors in Scala, aber ich halten den Empfang der Warnungen über nicht zugestellte Nachrichten. Dies ist der code für die main-Klasse, Collector ist eine separate Klasse, die

Bin ich gestellt mit dem folgenden problem: ich brauche, um die Arbeit aufzuteilen auf mehrere threads für die perfomance-Gründen, aber ich bin nicht sicher, was Ansatz zu nehmen. Erstens, die Aufgabe würde ich liefern sollte einen Wert

Ist es möglich, einen Actor warten für X Anzahl der Sekunden zu erhalten, jede Nachricht, und wenn eine Nachricht empfangen wird, verarbeiten Sie es wie gewohnt, ansonsten senden eine Nachricht zu einige andere Actor (pre-bestimmt im Konstruktor)?

Ich möchte haben die Möglichkeit, Schauspieler zu schlafen für eine Weile. Die Akteure sollten selbst entscheiden, wie lange Sie gehen, um zu schlafen. Als Thread.sleep() ist nicht eine empfohlene Weg, dies zu tun, ich dachte der mit

Hallo ich war der neue auf apache spark und ich war versucht, es zu lernen Während die Schaffung einer neuen, eigenständigen cluster traf ich mich mit diesem Fehler. Begann ich meinen master und ist aktiv in port

Ich würde gern ein Source und später push-Elemente, wie in: val src = ... //create the Source here //and then, do something like this pushElement(x1, src) pushElement(x2, src) Was ist der empfohlene Weg, dies zu tun? Dank!

Verstehe ich das spray macht das für mich, aber ich immer noch wollen, um es zu überschreiben mit meinem header, wie kann ich das überschreiben der header in der Antwort? Meine Antwort sieht wie folgt aus: case

Muss ich melden akka http-client, der Anfragen sowie deren Antworten. Während es scheint, einen Hauch von API zur Protokollierung von diesen Anforderungen, es gibt keine klare Dokumentation, wie es getan werden sollte. Mein Ansatz war die Schaffung

Ich Lerne akka-remoting-und dies ist, wie mein Projekt aussieht Die Projektstruktur sieht wie project/pom.xml project/mymodule/pom.xml project/mymodule/src/main/resources/application.conf project/mymodule/src/main/scala/com.harit.akkaio.remote.RemoteApp.scala project/mymodule/src/main/scala/com.harit.akkaio.remote.ProcessingActor.scala Wenn ich mein Projekt auf command-line sehe ich $ java -jar akkaio-remote/target/akka-remote-jar-with-dependencies.jar com.harit.akkaio.remote.RemoteApp Hello:com.harit.akkaio.remote.RemoteApp Exception in thread "main" com.typesafe.config.ConfigException$Missing:

Unten-Klasse verursacht ein Fehler in line new HelloWorld : Exception in thread "main" akka.actor.ActorInitializationException: You cannot create an instance of [HelloWorld] explicitly using the constructor (new). You have to use one of the 'actorOf' factory methods to

Hier ist, was ich zu finden bin, und für das Leben von mir ich kann nicht navigieren auf den Grund. Ich bin erstellen "Drucker" Akteure, die im Grunde entweder nichts tun, oder drucken Sie eine Nachricht auf

Ich versuche, eine bestehende ActorRef mit ActorFor oder eine neue erstellen wenn es nicht vorhanden ist. Ich habe folgenden code, aber es scheint nicht zu funktionieren, wie erwartet. .isTerminated() ist immer wahr. ActorSystem system = ActorSystem.create("System"); ActorRef

Ich versuche zu verstehen Futures und bitten Muster in akka. So, ich mache zwei Akteure, und man fragt, eine andere, ihn zurück zu senden a message. Gut, nach akka ist Futures Dokumentation, Schauspieler sollte Fragen(?) für die

Ich versuche Akka-http und hoffentlich kann jemand Licht auf eine der folgenden Fragen: Wie erzeugt man verschiedene Routen anhand der accept: - headers in der Anfrage? Zum Beispiel, ich möchte eine code-Pfad zu behandeln, "json" und zu

Ich bin interessiert zu wissen, wie um zu testen, Akka Schauspieler Funktionalität, von mocking einige Methoden (ersetzt die realen Objekts/Schauspieler-Methode, die Umsetzung von verspottet man) in Schauspieler. Benutze ich akka.testkit.TestActorRef; Auch: ich habe SpyingProducer aber es ist