I am implementing a simple http server which listens to requests and
persists them to Cassandra.
I have to split the stream in two using Broadcast so I am using Graphs.
I have something like this:
val bindingFuture: Future[Http.ServerBinding] =
> source.serverSource.to(Sink.foreach { connection => // foreach materializes
> the source
> system.log.debug("Accepted new connection from " +
> connection.remoteAddress)
> // ... and then actually handle the connection
> connection.handleWith(source.handleRequests)(server_materializer)
> }).run()(server_materializer)
>
>
And also
> val handleRequests = Flow[HttpRequest].mapAsyncUnordered(core.num_of_cores)(v
> => Future(requestHandler(v)))
>
>
> val requestHandler: HttpRequest => HttpResponse = {
> case HttpRequest(POST, Uri.Path("/stats"), headers, entity, protocol) =>
>
>
> val s =
> entity.withContentType(ContentTypes.`application/json`).getDataBytes()
> val g = FlowGraph.closed() { implicit builder =>
>
> import FlowGraph.Implicits._
> //....Bla bla bla...
>
>
> s ~> gflow ~> bcast ~> breakEvent ~> persistToC ~> out
> bcast ~> out
>
> }
> g.run()
>
> HttpResponse(200,headers = corsHeaders, entity = "Thanks!")
>
> case _: HttpRequest =>
> HttpResponse(404, entity = "Unknown resource!")
> }
>
>
I am calling `.run` twice and from what I understand a new stream will be
initiated for each request.
My plan is to setup an actor that will publish the entities downstream,
However I am not sure this is the correct approach.
Thanks in advance,
Raam
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
