Resultados de la búsqueda a petición "akka"
¿Por qué la transmisión por chispa no funciona bien cuando uso la aplicación extendidas?
El primer código arroja una excepción de puntero nulo. 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 ...
No se ha encontrado ninguna configuración para la clave 'akka.version'
Estoy aprendiendo akka-remoting y así es como se ve mi proyecto La estructura del proyecto se ve como project/pom.xml ...
¿Cómo crear una fuente que pueda recibir elementos más tarde a través de una llamada al método?
Me gustaría crear unSource y luego empujar elementos sobre él, como en: val src = ... // create the Source here // and then, do something like this pushElement(x1, src) pushElement(x2, src)cual es la manera recomendada para hacer esto? ¡Gracias!
Akka consolida solicitudes de bases de datos concurrentes
Quiero poder realizar solicitudes concurrentes a múltiples repositorios de datos y consolidar los resultados. Estoy tratando de entender si mi enfoque es válido o si hay una mejor manera de abordar este problema. Definitivamente soy nuevo en Akka ...
Akka DI moderno con Guice
Java 8, Guice 4.0 y Akka 2.3.9 aquí. Estoy tratando de descubrir cómo anotar mis clases de actor con el estilo JSR330@Inject anotaciones y luego conéctelas todas a través de Guice. Pero, literalmente, todos los artículos que he leído (algunos ...
Acceso al ActorRef subyacente de una fuente de flujo de akka creada por Source.actorRef
Estoy tratando de usar elSource.actorRef [http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-RC3/?_ga=1.155309435.1917589872.1429296441#akka.stream.scaladsl.Source$] método para crear ...
¿Cómo pruebo a un actor de Akka que envía un mensaje a otro actor?
Estoy usando ScalaTest con Akka TestKit para escribir pruebas de unidad e integración para un actor que he codificado para simplemente enviar un mensaje a otro actor sin mutar ningún estado interno. Toma esto por ejemplo: class MyActor extends ...
¿Por qué el patrón de "preguntar" del actor se considera un antipatrón o un "olor a código"?
Por lo que he reunido, el patrón de "preguntar" se considera una mala práctica y debe evitarse. En cambio, el patrón recomendado es el modelo "actor por solicitud". Sin embargo, esto no tiene sentido para mí, ya que el patrón "preguntar" hace ...
¿Akka obsoleto Camel?
Micomprensión de Akka es que proporciona un modelo mediante el cual múltiples hilos aislados pueden comunicarse entre sí de una manera muy concurrente. Utiliza el "modelo de actor", donde cada hilo es un "actor" con un trabajo específico que ...
Spray.io: no se puede compilar la especificación de prueba
Tengo el siguiente servicio: trait PingService extends MyHttpService { val pingRoutes = path("ping") { get { complete("message" -> "pong") } } }MyHttpServicees una clase personalizada que se extiendeHttpServicey solo contiene métodos de ...