Resultados da pesquisa a pedido "akka"
Diferença entre classe de caso e objeto de caso?
Estou aprendendo Scala e Akka e em minha pesquisa recente por umsolução [https://stackoverflow.com/questions/22770927/waiting-for-multiple-results-in-akka] , Eu encontrei algo como case class TotalTaxResult(taxAmount:Double) case object ...
O Custom Supervision.Decider não captura a exceção produzida pelo ActorPublisher
Estou construindo uma biblioteca que será usada por terceiros. Em um dos meus métodos eu retornoStream[Item] que é gerado de forma assíncrona a partir do resultado da chamada da API REST paginada. Estou usando minha modificação ...
akka HttpResponse lê o corpo como escala de String
Então, eu tenho uma função com esta assinatura (akka.http.model.HttpResponse): def apply(query: Seq[(String, String)], accept: String): HttpResponseEu simplesmente recebo um valor em um teste como: val resp = TagAPI(Seq.empty[(String, String)], ...
akka-http: Como definir cabeçalhos de resposta
Eu tenho uma rota da seguinte maneira: val route = { logRequestResult("user-service") { pathPrefix("user") { get { respondWithHeader(RawHeader("Content-Type", "application/json")) { parameters("firstName".?, "lastName".?).as(Name) { name => ...
Como um log de solicitações do cliente HTTP Akka
Preciso registrar as solicitações do cliente http akka, bem como suas respostas. Embora pareça haver uma dica da API para registrar essas solicitações, não há documentação clara sobre como isso deve ser feito. Minha abordagem foi criar ...
Qual ThreadPool em Java devo usar?
Há uma enorme quantidade de tarefas. Cada tarefa pertence a um único grupo. O requisito é que cada grupo de tarefas seja executado em série, exatamente como executado em um único encadeamento, e a taxa de transferência deve ser maximizada em um ...
Akka-http: como obter um cabeçalho personalizado a partir de uma solicitação?
Envio os seguintes cabeçalhos em uma solicitação para minha akka-http api:"Content-type": "application/json", "Accept": "application/json", "AppId": "some_id". Como obtenho o cabeçalho personalizado "AppId" na minha rota akka-http? (get & ...
Cliente Akka TCP: como enviar uma mensagem pelo TCP usando o akka actor
Quero enviar mensagens de texto por TCP. Bem fácil. Eu quero fazer isso com akka. Eu li este artigo sobre o akka IO: http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html [http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html] O artigo ...
Como zombar de um ator da Akka para testar uma unidade?
Eu tenho uma classe Controller que controla os pedidos enviados para um ator Akka que é injetado no controlador. Código do controlador: class Controller(actor: ActorRef) { def control(msg: String): Future[String] = { actor.ask(msg)(Timeout(2 ...
Como chamar corretamente um único servidor de vários atores / manipuladores da Web usando o Akka HTTP?
Eu tenho um serviço (vamos chamá-lo de Serviço A) que usa o Akka Server HTTP para lidar com solicitações recebidas. Também tenho aplicativo de terceiros (Serviço B), que fornece vários serviços da web. O objetivo do serviço A é transformar ...