Resultados da pesquisa a pedido "akka"
Cancelando o trabalho do Apache Flink a partir do código
Estou em uma situação em que quero parar / cancelar o trabalho de flink do código. Este é o meu teste de integração, no qual estou enviando uma tarefa ao meu trabalho de flink e verifico o resultado. Conforme o trabalho é executado de forma ...
Como abrir conexão TCP com TLS no scala usando akka
Quero escrever um cliente Scala que fale de um protocolo proprietário por uma conexão TCP com TLS. Basicamente, quero reescrever o seguinte código do Node.js no Scala: var conn_options = { host: endpoint, port: port }; tlsSocket ...
Incompatibilidade de tipo (String) usando classe de caso e ator
Algum problema de formato quando estou tentando citar o código, então aqui está a imagem :( descrição da imagem aqui [https://i.stack.imgur.com/4GAYi.jpg] import akka.actor.{Actor, ActorSystem, Props} case class Number(n: Int) case class ...
ERRO yarn.ApplicationMaster: exceção não capturada: java.util.concurrent.TimeoutException: futuros atingiram o tempo limite após 100000 milissegundos [duplicado]
Esta pergunta já tem uma resposta aqui: Por que a associação falha com "java.util.concurrent.TimeoutException: Futuros atingiram o tempo limite após [300 ...
Proxy Websocket usando o Play 2.6 e fluxos akka
Estou tentando criar um proxy simples para conexões Websocket usando os fluxos Play e akka. O fluxo de tráfego é assim: (Client) request -> -> request (Server) Proxy (Client) response <- <- response (Server)Eu vim com o seguinte código depois de ...
Play Framework, Akka, Guice: Como criar várias instâncias de um ator (que possui dependências) com o Guice dentro do controlador?
Há um exemplo no play framework doc ( https://www.playframework.com/documentation/2.6.x/ScalaAkka [https://www.playframework.com/documentation/2.6.x/ScalaAkka]) que explica como injetar ator (que possui dependências a serem injetadas) no ...
Parâmetro de conversão HTTP Scala Akka como java.time.ZonedDateTime
Estou trabalhando em um serviço REST usando o Akka HTTP (em Scala). Eu gostaria que um parâmetro que fosse passado para uma solicitação http get fosse convertido no tipo ZonedDateTime. O código funciona bem se eu tentar usar String ou Int, mas ...