Suchergebnisse für Anfrage "akka"
Wie starte ich Play 2.2.x mit Akka 2.3.x?
Gibt es eine Möglichkeit, Akka 2.3 und 2.2 zu kombinieren? Im Moment bekomme ich AbstractMethodError, während ich eine solche Anwendung laufen lasse. Ich muss beide in einer App haben, da Akka 2.3 mit einem sehr nützlichen Akka-Persistenzmodul ...
Warum funktioniert Spark-Broadcast nicht gut, wenn ich die App "Erweitert" verwende?
Der erste Code löst eine Nullzeigerausnahme aus. object TryBroadcast extends App{ val conf = new SparkConf().setAppName("o_o") val sc = new SparkContext(conf) val sample = sc.parallelize(1 to 1024) val bro = sc.broadcast(6666) val broSample = ...
Spray.io: Testspezifikation kann nicht kompiliert werden
Ich habe folgenden Service: trait PingService extends MyHttpService { val pingRoutes = path("ping") { get { complete("message" -> "pong") } } }MyHttpServiceist eine benutzerdefinierte Klasse, die @ erweiteHttpServiceund enthält nur ...
Gibt es in Akka leichte Schauspieler?
Mein Anwendungsfall ist sehr einfach: Zum Austauschen weniger (<100) Nachrichten zwischen zwei Objekten waren die Scala-Akteure für diesen Zweck hervorrag...
Akka Stream + Akka Http - Anfrage bei Fehler abrufen
Ich habe den folgenden Stream, der ziemlich gut funktioniert: source .map(x => HttpRequest(uri = x.rawRequest)) .via(Http().outgoingConnection(host, port)) .to(Sink.actorRef(myActor, IsDone)) .run() und ein einfacher Akteur, der den ...
Wie konvertiere ich Map [A, Future [B]] nach Future [Map [A, B]]?
Ich habe mit der Scala Akka-Bibliothek gearbeitet und bin auf ein Problem gestoßen. Wie der Titel sagt, muss ich konvertieren
Schalten Sie die Slick-Abmeldung aus
Slick füllt die Konsole mit einer Unmenge von Protokollnachrichten. Ich wollte, wie in der Dokumentation vorgeschlagen, verwendenslf4j-nopDaher ist die Protokollierung deaktiviert, aber Akka benötigt eine eigene slf4j-Bibliothek. Also bin ich ...
Umwandlung von Akkas Zukunft [A] in Zukunft [Entweder [Ausnahme, A]]
Gibt es eine Methode in Akka (oder in der Standardbibliothek in Scala 2.10) um a
Welchen ThreadPool in Java soll ich verwenden?
Es gibt eine Menge Aufgaben. Jede Aufgabe gehört zu einer einzelnen Gruppe. Die Anforderung ist, dass jede Gruppe von Aufgaben wie in einem einzelnen Thread seriell ausgeführt wird und der Durchsatz in einer Umgebung mit mehreren Kernen (oder ...