Resultados de la búsqueda a petición "akka"
akka-stream: cómo tratar el último elemento de una secuencia de manera diferente en un flujo / gráfico
Estoy tratando de implementar un Akka StreamsFlow eso convertirá una secuencia de objetos JSON en una secuencia de una sola matriz de objetos JSON. Puedo usarConcat para agregar un "[" antes y "]" después, así comoZip para insertar comas entre ...
Java Spring como cliente para llamada HTTP REST basada en Akka
Tengo que llamar a este servicio REST escrito enscala-akka proyecto dejava-spring. mi servicio scala REST es como val route = post { path("notification" / "signUp"){ headerValueByName("App_Key") { app_key => { handleWith { requestParameters: ...
Secuencia de eventos de Akka Persistence Query y CQRS
Estoy tratando de implementar el lado de lectura en mi arquitectura ES-CQRS. Digamos que tengo un actor persistente como este: object UserWrite { sealed trait UserEvent sealed trait State case object Uninitialized extends State case class ...
Consume el flujo TCP y redirige a otro sumidero (con Akka Streams)
Intento redirigir / reenviar una secuencia TCP a otro sumidero con Akka 2.4.3. El programa debe abrir un socket de servidor, escuchar las conexiones entrantes y luego consumir el flujo tcp. Nuestro remitente no espera / acepta respuestas de ...
Cancelar el trabajo de Apache Flink desde el código
Estoy en una situación en la que quiero detener / cancelar el trabajo de parpadeo del código. Esto está en mi prueba de integración donde estoy enviando una tarea a mi trabajo de flink y verifico el resultado. A medida que el trabajo se ejecuta, ...
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 ...
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 ...
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 ...
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 ...
¿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?