Re: [akka-user] Re: Http Client with Source.tick
Cool, happy hAkking! -- Cheers, √ On Mar 11, 2016 12:11 AM, "Arun Sethia" wrote: > Super ... you guys are awesome ... more I am learning, it is becoming more > and more interesting. > > I used recover, It worked well. Thanks a lot. > > > On Thursday, March 10, 2016 at 4:52:30 PM UTC-6, √ wrote: >> >> >> http://doc.akka.io/api/akka/2.4.2/?_ga=1.176202021.1085570125.1455222020#akka.stream.scaladsl.FlowOps >> >> -- >> Cheers, >> √ >> On Mar 10, 2016 11:43 PM, "Arun Sethia" wrote: >> >>> Thanks. >>> >>> please can you provide the link where I can see how to deal with such >>> errors. >>> >>> On Thursday, March 10, 2016 at 4:22:35 PM UTC-6, √ wrote: For each only deals with elements, not errors. Please consult the documentation for combinators that let you observe and manipulate errors. -- Cheers, √ On Mar 10, 2016 11:04 PM, "Arun Sethia" wrote: > 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 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. > -- >>> >> 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. >>> >> -- > >> 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+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- >> Read the do
Re: [akka-user] Re: Http Client with Source.tick
Super ... you guys are awesome ... more I am learning, it is becoming more and more interesting. I used recover, It worked well. Thanks a lot. On Thursday, March 10, 2016 at 4:52:30 PM UTC-6, √ wrote: > > > http://doc.akka.io/api/akka/2.4.2/?_ga=1.176202021.1085570125.1455222020#akka.stream.scaladsl.FlowOps > > -- > Cheers, > √ > On Mar 10, 2016 11:43 PM, "Arun Sethia" > > wrote: > >> Thanks. >> >> please can you provide the link where I can see how to deal with such >> errors. >> >> On Thursday, March 10, 2016 at 4:22:35 PM UTC-6, √ wrote: >>> >>> For each only deals with elements, not errors. >>> Please consult the documentation for combinators that let you observe >>> and manipulate errors. >>> >>> -- >>> Cheers, >>> √ >>> On Mar 10, 2016 11:04 PM, "Arun Sethia" wrote: >>> 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 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. >>> -- >> >> 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. >> > -- >> 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+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Re: Http Client with Source.tick
http://doc.akka.io/api/akka/2.4.2/?_ga=1.176202021.1085570125.1455222020#akka.stream.scaladsl.FlowOps -- Cheers, √ On Mar 10, 2016 11:43 PM, "Arun Sethia" wrote: > Thanks. > > please can you provide the link where I can see how to deal with such > errors. > > On Thursday, March 10, 2016 at 4:22:35 PM UTC-6, √ wrote: >> >> For each only deals with elements, not errors. >> Please consult the documentation for combinators that let you observe and >> manipulate errors. >> >> -- >> Cheers, >> √ >> On Mar 10, 2016 11:04 PM, "Arun Sethia" wrote: >> >>> 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 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. >>> >> -- > >> 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+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- >> 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+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Re: Http Client with Source.tick
Thanks. please can you provide the link where I can see how to deal with such errors. On Thursday, March 10, 2016 at 4:22:35 PM UTC-6, √ wrote: > > For each only deals with elements, not errors. > Please consult the documentation for combinators that let you observe and > manipulate errors. > > -- > Cheers, > √ > On Mar 10, 2016 11:04 PM, "Arun Sethia" > > wrote: > >> 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 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. >> > -- >> 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+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Re: Http Client with Source.tick
For each only deals with elements, not errors. Please consult the documentation for combinators that let you observe and manipulate errors. -- Cheers, √ On Mar 10, 2016 11:04 PM, "Arun Sethia" wrote: > 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 akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- >> 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+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Re: Http Client with Source.tick
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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.