Re: [akka-user] Apply different functions on SubFlows

Thanks a lot!! On Tuesday, 25 April 2017 18:39:58 UTC+7, Akka Team wrote: > > Partition allows you to look at a message and decide which of its outlets > to pass the element to, this way you can design the logic of each sub > stream independently. Something like this: > > val flow: Flow[Int,

Re: [akka-user] Is Akka Multi Node Testing available in Java

OK, thanks. On Tuesday, 25 April 2017 16:59:10 UTC+8, Akka Team wrote: > > Hi Dai, > > I'm afraid it is currently only possible to run the multi-node tests with > Scala + SBT > > -- > Johan > Akka Team > > On Wed, Mar 22, 2017 at 3:11 AM, Dai Yinhua > wrote: > >> Anybody

Re: [akka-user] Akka HTTP/JSON: Rejecting requests with unknown fields

On Wednesday, March 29, 2017 at 7:13:28 AM UTC-4, Konrad Malawski wrote: > In principle sure, though not on anyones roadmap nowadays. > You could contribute such a thing or find a json parser whihc has such > failure mode - I'm unaware of any parser which has such failure mode though. >

Re: [akka-user] Akka HTTP client - Advice for executor context

Great explanation Arne - thank you! I think I have all pieces except one: I call web services in parallel, creating Futures. Futures are then converted to one Future (like Future.sequence). Do I reach backpressure in case of "too many requests" when router respond with Source

Re: [akka-user] Akka HTTP client - Advice for executor context

Great explanation Arne - thank you! I think I have all pieces except one: I call web services in parallel, creating Futures. Futures are then converted to one Future (like *Future.sequence*). When, in router, I create response with Source and set OverflowStrategy.backpressure 2017-04-26 10:15

Re: [akka-user] Akka HTTP/JSON: Rejecting requests with unknown fields

That Jackson support is for JavaDSL though - do not mix the DSLs. It is absolutely possible and supported to use Jackson in ScalaDSL though: It's implemented by Heiko's library here: https://github.com/hseeberger/akka-http-json Hope this helps - -- Konrad `ktoso` Malawski Akka

[akka-user] Akka http compilation error due to _marshaller

Hi, I am using akka http for graphql sangria subscription. It is working fine in example application but while integrating graphql subscription code with this simple query mutation code it is giving compilation error. Below is the

Re: [akka-user] Akka HTTP client - Advice for executor context

> /_Question_:/ > - does it make really sense to create dispatcher pro web service client > or one for all? Do you've any experience with it? > - is it better to use Dispatcher with fork-join or fixed-size one? Using the default pool fully utilizes the CPU, and using a separate dispatcher will

Re: [akka-user] Multi Host Master with Remote Worker

These two sample projects shows an example of this: https://github.com/typesafehub/activator-akka-distributed-workers https://github.com/typesafehub/activator-akka-distributed-workers-java -- Johan Akka Team On Fri, Mar 3, 2017 at 9:52 PM, wrote: > How do i create Master

Re: [akka-user] Akka HTTP client - Advice for executor context

Thank you Konrad for really fast response! I read the docs again and if I correct understood my configuration can/should be like this one: *1. Dispatcher(s)* One dispatcher for all web service clients with fixed size. Size of the pool correspond to CPU amount (16 for 16 cores) *or* dispatcher