httpSourceGraph1 is httpSourceGraph , but still same issue
val response= httpSourceGraph.via(httpConnFlow()).runForeach(println)
we can test same with any external internet URL also, the result remain same.
On Thursday, March 10, 2016 at 3:55:22 PM UTC-6, Arun Sethia wrote:
>
> Hi,
>
> I am trying to connect http client to a http service exposed by server,
> the source should send request every 1 second for that I have crated
> following partial graphs:
>
>
> def httpSourceGraph() = {
> Source.fromGraph(GraphDSL.create() { implicit builder =>
> val sourceOutLet = builder.add(Source.tick(FiniteDuration(0,
> TimeUnit.SECONDS), FiniteDuration(1,
> TimeUnit.SECONDS),
> HttpRequest(uri ="/test", method = HttpMethods.GET))).out
> // expose outlet
> SourceShape(sourceOutLet)
> })
> }
>
>
> def httpConnFlow() = {
> Flow.fromGraph(GraphDSL.create() { implicit builder =>
>
> val httpSourceFlow = builder.add(Http(system).outgoingConnection(host =
> "localhost", port = 8080))
>
> FlowShape(httpSourceFlow.in, httpSourceFlow.out)
> })
> }
>
>
> the graph is composed as
>
>
> val response= httpSourceGraph1.via(httpConnFlow()).runForeach(println)
>
>
> if the http server (localhost:8080/test) is up and running, everything works
> fine, every 1 second I can see the response coming back from the server. I am
> not able to any response in case of either server is down or it goes down
> later.
>
>
> *I think it should give me following error:*
>
>
> akka.stream.StreamTcpException: Tcp command
> [Connect(localhost/127.0.0.1:8080,None,List(),Some(10 seconds),true)] failed
>
>
> Thanks for the help.
>
> -Arun
>
>
>
>
>
--
>>>>>>>>>> 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 [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
