I have a long-running source which can pause for periods of several minutes during message emission. I then use this in akka http to post to a spring service. However if any pause reaches one minute the http post times-out and completes the post with code 200. I have tried all the config parameters suggested in the documentation but they are having no effect,
akka.http.server.idle-timeout=120s
akka.http.client.idle-timeout=120s
akka.http.host-connection-pool.idle-timeout=120s
akka.http.host-connection-pool.client.idle-timeout=120s
similar to this issue (https://github.com/akka/akka/issues/16597). My code looks like this:
Http httpContext =
Http.get(context().system());
Source<ByteString, NotUsed> chunked =
mysource.map(str -> ByteString(str.concat("\n")))
.concat(Source.single(ByteString.empty()));
HttpRequest post = HttpRequest.POST("http://some-server/address")
.withEntity(HttpEntities.createChunked(ContentTypes.APPLICATION_OCTET_STREAM, chunked))
.withProtocol(HttpProtoclas.HTTP_1_1);
CompletionStage<HttpResponse> result =
httpContext.singleRequest(post, materializer);
Using 10.0.2. This is a show stopper for us, can anyone help?
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+...@googlegroups.com.
To post to this group, send email to akka...@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.