akka

5calore

1risposta

Risposta tardiva da async io in Akka

Sto usando akka per un po 'di tempo. Ho iniziato a vedere alcuni modelli nel mio codice per risolvere la risposta tardiva per async io. Questa implementazione è ok? C'è un altro modo per fare una risp

scala akka 2012-08-23

---

22calore

1risposta

Processo in esecuzione prolungata con barra di avanzamento Esempio PlayFramework 2

Sto tentando di implementare un processo in background di lunga esecuzione che viene generato quando un utente visita una pagina. Vorrei visualizzare l'avanzamento dell'attività proprio come in questo

java playframework-2.0 akka 2012-07-09

---

17calore

1risposta

Akka :: dispatcher [% nome%] non configurato, utilizzando default-dispatcher

ho creato l'application.conf followind: akka { actor { prio-dispatcher { type = "Dispatcher" mailbox-type = "my.package.PrioritizedMailbox" } } } quando il d

configuration akka dispatcher 2012-08-30

---

5calore

1risposta

Akka :: Utilizzo di messaggi con priorità diverse sul flusso di eventi in ActorSystem

Devo pubblicare messaggi di tipi diversi per il flusso di eventi, e quei messaggi dovrebbero avere priorità diverse ad esempio, se 10 messaggi di tipo A sono stati pubblicati, e dopotutto un messaggio

actor akka publish-subscribe priority-queue 2012-08-30

---

7calore

1risposta

Messaggio di errore con Scala AKKA Attore

Ecco il mio codice: class testActor extends Actor { var test = "test2" def receive = { case "test" ⇒ "works" } } def test = Action { var test = "test" val s

scala akka 2012-07-13

---

13calore

2risposta

Come faccio a racchiudere un java.util.concurrent.Future in un futuro Akka?

In un'applicazione Play Framework 2.0.1 (Scala), stiamo utilizzando una libreria client di servizi Web che restituisce java.util.concurrent.Future come risposte. Invece di bloccare Play app sulla chia

scala playframework-2.0 akka future 2012-07-17

---

5calore

1risposta

terminano correttamente gli attori akka in scala

Ho scritto codice di esempio che avvia un attore, lo uccide e termina l'esecuzione. object PureAkka { def main(argv : Array[String]) = { val actorSystem : ActorSystem = ActorSystem("main")

scala actor akka 2012-09-07

---

5calore

1risposta

Il metodo Akka onReceive viene eseguito contemporaneamente?

Ecco il mio scenario: Ho un attore principale, che riceve messaggi da più attori secondari. Questi messaggi contengono dati da aggregare. In questa logica di aggregazione, devo occuparmi dei problemi

synchronization actor akka 2012-07-26

---

9calore

7risposta

Come aspettare che il sistema di attori Akka termini?

Ho bisogno di avviare il sistema di attori Akka (2.0), inviare alcuni messaggi, quindi attendere che faccia il sollevamento pesi. Dopodiché, ho bisogno di fare qualcosa che non sia correlato a quegli

scala akka 2012-09-15

---

6calore

1risposta

Ottenere un'applicazione remota Akka semplice in esecuzione

Sto provando a configurare una semplice applicazione server/client akka (utilizzando Akka 2.0.3), ma non è riuscita a connettersi. Precedentemente ecco il codice base: import com.typesafe.config.Confi

scala akka 2012-09-22

---