Resultados da pesquisa a pedido "akka-http"
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 => ...
Kubernetes - Akka clustering Deployment
Temos uma imagem do docker e um arquivo yaml correspondente para a implantação usando o kubernetes. O aplicativo que criamos está em scala com akka-http. Nós usamos o akka-cluster. Temos uma variável específica (nós de sementes no nosso caso - ...
Como lidar com o tempo limite de resposta?
No roteamento akka-http, posso retornarFuture como uma resposta que converte implicitamente emToResponseMarshaller. Existe alguma maneira de lidar com o tempo limite deste futuro? Ou tempo limite da conexão no nível da rota? Ou uma maneira é ...
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 & ...
Os auxiliares de teste do Play Framework precisam de `Materializer` implícito
Estou usando o Play 2.6.xe o auxiliar de teste parastatus(result) tem o método: def status(of: Accumulator[ByteString, Result])(implicit timeout: Timeout, mat: Materializer): Int = status(of.run()) A execução de testes é lançada quando o ...
Como usar o websocket do cliente Akka-HTTP, enviar mensagem
Estou tentando o websocket do lado do cliente seguindo o documento em webSocketClientFlow [http://doc.akka.io/docs/akka/2.4/scala/http/client-side/websocket-support.html#webSocketClientFlow] . código de exemplo é: import akka.actor.ActorSystem ...
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 ...
Akka Stream + Akka Http - Obter solicitação por erro
Eu tenho o seguinte fluxo que funciona muito bem: source .map(x => HttpRequest(uri = x.rawRequest)) .via(Http().outgoingConnection(host, port)) .to(Sink.actorRef(myActor, IsDone)) .run()e um agente simples para lidar com o status da resposta e a ...
O Akka Flow trava ao fazer solicitações HTTP via pool de conexão
Estou usando o Akka 2.4.4 e tentando sair do Apache HttpAsyncClient (sem êxito). Abaixo está a versão simplificada do código que eu uso no meu projeto. O problema é que ele trava se eu enviar mais de 1 a 3 solicitações para o fluxo. Até agora, ...
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)], ...
Página 1 do 2