akka

7calore

1risposta

Akka-streaming HTTP usando Slick 3.0 Databasepublisher

Sto usando chiazza di petrolio 3.0 e dispone di un oggetto databasepublisher come def getAsStream = db.stream[Entity](tblquery.result) Sto usando Akka-http per lo strato di riposo come segue, val ro

9calore

1risposta

SLF4J: percorso classe contiene più binding SLF4J. messaggio stampato su console

Desidero stampare i registri su console e scriverli in un file. Nel mio progetto Scala usando Akka logger ecco il mio build.sbt libraryDependencies ++= Seq("org.mongodb" %% "casbah" % "2.8.0",

7calore

1risposta

Risoluzione del futuro Akka da chiedere in caso di guasto

Sto chiamando un attore che utilizza il modello ask all'interno di un'applicazione Spray e restituisce il risultato come risposta HTTP. Mappo i fallimenti dall'attore a un codice di errore personalizz

5calore

2risposta

Akka - come verificare per quanto tempo un messaggio era in arrivo?

Come verificare akka per quanto tempo un messaggio era in arrivo? Voglio fare un messaggio di log se il messaggio era in arrivo per troppo tempo. Qualcosa del tipo: override def receive: Receive = {

7calore

1risposta

Akka: comunicare al di fuori del sistema dell'attore?

Ho il seguente/classe principale driver di incapsulare il mio programma di Akka: // Groovy pseudo-code class FizzBuzz { ActorSystem actorSystem static void main(String[] args) { Fizz

5calore

1risposta

Configurazione Typesafe: carica configurazione da src/test/risorse

Questa è una domanda per principianti. Quindi la mia struttura app assomiglia src/main/java/... src/main/resources/application.conf src/test/java/... src/test/resources/module/test.module.conf a

5calore

1risposta

Come inviare nuovamente il messaggio dopo che l'attore è stato riavviato dalla strategia del supervisore

Ho un attore principale (A) con due attori secondari (B). Ho realizzato una strategia di supervisione in A, quindi nel caso in cui si verifichi un'eccezione specifica in B, B verrà riavviato. Come pos

9calore

1risposta

Importanza di router Akka

Ho questo dubbio persistente riguardo all'importanza dei router Akka. Ho usato Akka Routers nell'attuale progetto a cui sto lavorando. Tuttavia, sono un po 'confuso sull'importanza di ciò. Tra i due m

5calore

1risposta

Come collegare più attori come sorgenti ad un flusso Akka?

Sto cercando di costruire e gestire un flusso di flusso Akka (in Java DSL) con 2 attori come fonti, poi un bivio unione e poi 1 lavello: Source<Integer, ActorRef> src1 = Source.actorRef(100, OverflowS

9calore

1risposta

In Slick 3.0, perché è utile il nuovo Streaming?

Ho trovato Slick 3.0 ha introdotto una nuova funzionalità denominata streaming http://slick.typesafe.com/doc/3.0.0-RC1/database.html#streaming io non sono a conoscenza Akka. streaming sembra un valore