akka

6calore

2risposta

Lo scala offre IO asincroni non bloccanti quando si lavora con i file?

Sto usando scala 2.10 e mi chiedo se ci sia qualche pacchetto con IO asincrono quando si lavora con i file? ho fatto qualche ricerca o questo argomento, ma per lo più trovato esempi seguenti val file

11calore

2risposta

Dove dovrebbero essere dichiarati i messaggi degli attori?

Sto sviluppando un'applicazione che utilizza Akka e una cosa che mi infastidisce per tutto il tempo che riguarda la dichiarazione dei messaggi con lo Actor. Dove dovrei dichiarare i messaggi? Nell'ogg

8calore

2risposta

Come utilizzare Reactive Stream per l'elaborazione binaria NIO?

Esistono esempi di codice dell'utilizzo delle librerie org.reactivestreams per elaborare grandi flussi di dati utilizzando Java NIO (per prestazioni elevate)? Sto puntando all'elaborazione distribuita

6calore

1risposta

Spionaggio con mockito sull'attore Akka

Vorrei spiare l'istanza del mio attore, ma non può essere semplicemente creato con una nuova parola chiave. Ho capito la seguente soluzione: val testActorSpy = spy(TestActorRef(new TestActor).underlyi

15calore

1risposta

Il logger log1-Slf4jLogger non ha risposto entro Timeout (5000 millisecondi) a InitializeLogger (bus)

Sto eseguendo un'applicazione Akka con Akka Kernel e il programma funziona bene in altri sistemi. akka { loggers = ["akka.event.slf4j.Slf4jLogger"] loglevel = INFO } Qual è la corretta co

6calore

2risposta

non riusciva a trovare implicita ...: akka.http.server.RoutingSetup

Giocando con, Akka-http sperimentale 1.0-M2 Sto cercando di creare un semplice Ciao esempio del mondo. import akka.actor.ActorSystem import akka.http.Http import akka.http.model.HttpResponse import

10calore

1risposta

Spray.io: impossibile compilare prova spec

Ho il seguente servizio: trait PingService extends MyHttpService { val pingRoutes = path("ping") { get { complete("message" -> "pong") } } } MyHttpService è una classe

7calore

1risposta

Nell'attore persistente di Akka, sta creando un attore bambino considerato un effetto collaterale o la creazione di uno stato?

Questa domanda non è così filosofica come potrebbe suggerire il titolo. Considerare il seguente approccio alla persistenza: I comandi per eseguire operazioni provengono da vari client. Rappresento sia

5calore

1risposta

Instradamento remoto di Akka problema di configurazione nome host

Sto sperimentando la funzionalità remota di akka per uno strumento che sto creando. In realtà, sono riuscito a far funzionare i sistemi principali e remoti nello stesso host con diverse porte. Si noti

6calore

1risposta

Modo corretto per posticipare i messaggi in Akka

Sto usando il cluster akka per eseguire calcoli distribuiti in due pahses. Prima phaseA quindi phaseB. Per gestire le fasi uso l'FSM di akka. Non è presente alcuna sincronizzazione hardware, pertanto