[akka-user] Sharded replication with distributed data

2017-08-15 Thread Igor Baltiyskiy
Hi, I'm wondering whether "sharded replication" is possible with Akka. Let me describe that in more detail. In my model, entities contain caches that are very expensive to recreate from scratch (because they cache results of multiple calls to several external systems). So I can't just use clus

[akka-user] Event Sourcing/CQRS Database constraints on Read Only Side

2017-08-15 Thread BlueCar
Our company would like to implement Event Sourcing/CQRS for our financial systems. For the Read Only Model, should we apply Database SQL constraints? I know constraints should Not be on the Write event store side. How about the Read only Model side? Including: Unique Constraints Foreign Key C

[akka-user] Re: [akka-http] Http().superPool() and MergeHub.source backpressure

2017-08-15 Thread Jeff
I'm embarrassed I forgot something so obvious. Much thanks! On Tuesday, August 15, 2017 at 8:50:27 AM UTC-7, johannes...@lightbend.com wrote: > > Hi Jeff, > > if you don't read the response bodies of all the responses, your pipeline > will stall because the super pool connection are still waitin

[akka-user] Re: [akka-http] adding cookie attributes

2017-08-15 Thread johannes . rudolph
Hi Christophe, yes, that's correct. There seems to be no way to model custom cookie attributes right now. Using RawHeader is the right workaround for now. I filed https://github.com/akka/akka-http/issues/1354 to discuss improvements. Johannes On Monday, August 14, 2017 at 10:31:11 AM UTC+2, Ch

[akka-user] Re: [akka-http] Http().superPool() and MergeHub.source backpressure

2017-08-15 Thread johannes . rudolph
Hi Jeff, if you don't read the response bodies of all the responses, your pipeline will stall because the super pool connection are still waiting for your code to actually read the responses. In your example, try to add `x.discardEntityBytes` (or actually read the entity) inside of the `Sink.f

[akka-user] Re: Akka HTTP usage of HttpEntity.toStrict

2017-08-15 Thread johannes . rudolph
Hi Yannick, if you want to log the complete request contents, then there is no other way than to collect anything into memory (actually, that's a consequence of logging, not of the API). In that case, you can use toStrict method or the toStrictEntity directive at the root of your routing tree

[akka-user] sbt-revolver 0.9.0 released with sbt 1.0.0 support

2017-08-15 Thread johannes . rudolph
Dear fast application restarters, we just released sbt-revolver 0.9.0 which is the first version of sbt-revolver cross-built for sbt 0.13.x and 1.0.x. Thanks go to Olli Helenius / @liff who contributed the sbt 1.0 compatibility changes (#62). We also merged a long-standing PR that allows to custo

[akka-user] sbt-revolver 0.9.0 released with sbt 1.0.0 support

2017-08-15 Thread 'Johannes Rudolph' via Akka User List
Dear fast application restarters, we just released sbt-revolver 0.9.0 which is the first version of sbt-revolver cross-built for sbt 0.13.x and 1.0.x. Thanks go to Olli Helenius / @liff who contributed the sbt 1.0 compatibility changes (#62). We also merged a long-standing PR that allows to custo

Re: [akka-user] Re: [Akka-typed] Mutable Behavior testing with EffectfulActorContext

2017-08-15 Thread Nishant Vishwakarma
Hi, Its not the supervisor that sends the message. Its the child which upon > instantiation sends itself a message using 'ctx.self ! InitializeWorker'. I > was hoping to see that message in the child inbox. However I realize that > when Supervisor says ctx.spawnAnonymous using a StubbedActorCon