Resultados de la búsqueda a petición "akka"
Error al intentar hacer que un actor persistente requiera un buzón personalizado con RequiereMessageQueue
Intento lo siguiente: class ClientActor (stockActor: ActorSelection, paymentsActor: ActorSelection) extends PersistentActor with AtLeastOnceDelivery with akka.actor.ActorLogging with RequiresMessageQueue[akka.custom.CustomMailbox]{ //actor ...
Escriba la falta de coincidencia (String) usando la clase de caso y el actor
Algún problema de formato cuando intento citar el código, así que aquí está la imagen :( descripción de la imagen aquí [https://i.stack.imgur.com/4GAYi.jpg] import akka.actor.{Actor, ActorSystem, Props} case class Number(n: Int) case class ...
Cómo hacer una llamada POST al servidor autocertificado con akka-http
Tengo una topología de akka-streams, donde hago una llamada POST usando akka-http. Recibo el siguiente error cuando llego a la solicitud de publicación en un servidor no seguro (que tiene certificados autofirmados). Es un servidor interno, así ...
ERROR yarn.ApplicationMaster: Excepción no detectada: java.util.concurrent.TimeoutException: El tiempo de espera expiró después de 100000 milisegundos [duplicado]
Esta pregunta ya tiene una respuesta aquí: ¿Por qué falla la unión con "java.util.concurrent.TimeoutException: Futures expiró después de [300 ...
Parámetro de conversión de Scala Akka HTTP como java.time.ZonedDateTime
Estoy trabajando en un servicio REST usando Akka HTTP (en Scala). Me gustaría que un parámetro que se pasa a una solicitud de obtención de http se convierta al tipo ZonedDateTime. El código funciona bien si intento usar String o Int pero falla ...
Play Framework, Akka, Guice: ¿Cómo crear múltiples instancias de un actor (que tiene dependencias) con Guice dentro del controlador?
Hay un ejemplo en play framework doc ( https://www.playframework.com/documentation/2.6.x/ScalaAkka [https://www.playframework.com/documentation/2.6.x/ScalaAkka]) que explica cómo inyectar actor (que tiene dependencias para inyectar) en el ...
¿Cómo funciona akka stream throttle?
def throttle(elements: Int, per: FiniteDuration, maximumBurst: Int, mode: ThrottleMode): Repr[Out]HacemaximumBurst significa la cantidad de elementos que se pueden procesar al mismo tiempo?
Akka modificando / creando un archivo de configuración a partir del código fuente
¿Es posible modificar o crear un archivo de configuración a partir del código fuente? Estoy creando una arquitectura cliente / servidor con comunicación remota. Lo que quiero cumplir es la capacidad de iniciar la aplicación cliente con, por ...
Websocket Proxy usando Play 2.6 y transmisiones de akka
Estoy tratando de crear un Proxy simple para conexiones Websocket usando Play y akka streams. El flujo de tráfico es así: (Client) request -> -> request (Server) Proxy (Client) response <- <- response (Server)Se me ocurrió el siguiente código ...
Cómo abrir una conexión TCP con TLS en scala usando akka
Quiero escribir un cliente Scala que hable un protocolo propietario sobre una conexión TCP con TLS. Básicamente, quiero reescribir el siguiente código de Node.js en Scala: var conn_options = { host: endpoint, port: port }; tlsSocket ...