Re: [akka-user] WebSocket + AKKA + Redis pub/sub

The original question about WebSocket + Akka + Redis was 2 years ago. Now, you don't need Redis any more, because: * Akka is already very good at messaging. * Recent versions of Akka have clustering feature: http://doc.akka.io/docs/akka/2.3.5/scala/cluster-usage.html In short, you only need WebS

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

You can relatively easily support process managers on top (event store assures idempotency) On Wed, Aug 20, 2014 at 5:46 PM, Gary Malouf wrote: > Greg - if one uses the current Akka Persistence with eventstore as the > backend, is it possible/what are the challenges in getting safe 'process > m

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

Greg - if one uses the current Akka Persistence with eventstore as the backend, is it possible/what are the challenges in getting safe 'process managers' to work as one would expect? I would think you'd want event store feeding a different Akka Persistence processor. On Wed, Aug 20, 2014 at 2:10

[akka-user] Question about: Make entries of shards persistent

Hi, I saw this tweet by Patrik: 'Fantastic #Akka contribution by Dominic Black merged to master. Cluster sharding remembers active entries. https:// github.com/akka/akka/pull/15597 … ' I think it is a really cool feature to be

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

Whilst we are talking about s... process managers I would like to include this simple way of understanding them I found on the web: "Process Managers produce commands and consume events, whereas Aggregate Roots consume commands and produce events." The truth is a bit more complicated I believ

Re: [akka-user] Testing parent/child behaviors

Tom, Why don't you use a protected factory method (`def createChild: ActorRef = ...`) in the parent to create your child actor instead of doing it inline? Then override it the way you want in the tests. Sometimes good old OO (I know that Alan Kay not necessarily meant inheritance when inventing

Re: [akka-user] Using stash with become

Hi Heiko, That actually makes a lot of sense. I keep forgetting that things within an actor happen on a message by message basis. Thanks for the clarification! Luis On Tuesday, August 19, 2014 10:59:36 PM UTC-7, Heiko Seeberger wrote: > > Luis, > > As an actor only handles one message at a time

[akka-user] Re: [akka-stream] : Streaming large file from 1 server to 1 client

Thanks I check this, I also compute a checksum on the fly with a closed value inside the map. I've seend it's a bad practice and will refactored it in this way: https://groups.google.com/forum/#!topic/akka-user/i21YLDj5YTw (post about lost data in TCP Echo) I keep you informed asap Le mardi 1

[akka-user] Testing parent/child behaviors

I've already looked at all the links from https://www.assembla.com/spaces/akka/tickets/3043#/activity/ticket: as well as http://hs.ljungblad.nu/post/69922869833/testing-parent-child-relationships-in-akka Still no closer to actually finding a working solution for testing an actor which spawns a

Re: [akka-user] Re: [akka-stream] : Streaming large file from 1 server to 1 client

Hi Xavier, seems like a potential bug related to the TcpStream and not the chunker: This works for me: def testNoNetwork(fileLength: Int, chunkSize: Int) { implicit val actorSystem = ActorSystem("test", ConfigFactory.parseString( """akka { | log-dead-letters = 0 | log-dead-lett

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

further explanation http://soa.dzone.com/news/are-sagas-and-workflows-same-t On Wed, Aug 20, 2014 at 10:39 AM, Greg Young wrote: > I held the same issue with ms pnp > > Clarifying the terminology > > The term saga is commonly used in discussions of CQRS to refer to a piece > of code that coordi

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

I held the same issue with ms pnp Clarifying the terminology The term saga is commonly used in discussions of CQRS to refer to a piece of code that coordinates and routes messages between bounded contexts and aggregates. However, for the purposes of this guidance we prefer to use the term process

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

20 aug 2014 kl. 16:16 skrev Greg Young : > Please stop using the terminology of "saga" and replace usage with "process > manager" what people (largely influenced by nservicebus call a saga is > actually a process manager and a saga is a different pattern). Its bad enough > the .net community d

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

Please stop using the terminology of "saga" and replace usage with "process manager" what people (largely influenced by nservicebus call a saga is actually a process manager and a saga is a different pattern). Its bad enough the .net community does this the last thing we need is for the akka commun

[akka-user] Re: [akka-stream] : Streaming large file from 1 server to 1 client

Hello Viktor, Thanks a lot for your answer. I've tried your solution and passed from version 0.3 to 0.5 of akka-stream modules. But problem is still there. I've extracted part of the code into a Gist. https://gist.github.com/xbucchiotty/3fab493607588dec0ac8 Streaming a file of 10.MB with a chu

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

Am 20.08.2014 13:33 schrieb "Roland Kuhn" : > > > 20 aug 2014 kl. 10:43 skrev Martin Krasser : > >> On 20.08.14 10:16, Roland Kuhn wrote: >>> >>> >>> 19 aug 2014 kl. 18:59 skrev Ashley Aitken : >>> On Tuesday, 19 August 2014 21:14:17 UTC+8, rkuhn wrote: > > > 18 aug 2014 kl. 18:01

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

20 aug 2014 kl. 10:43 skrev Martin Krasser : > On 20.08.14 10:16, Roland Kuhn wrote: >> >> 19 aug 2014 kl. 18:59 skrev Ashley Aitken : >> >>> On Tuesday, 19 August 2014 21:14:17 UTC+8, rkuhn wrote: >>> >>> 18 aug 2014 kl. 18:01 skrev Ashley Aitken : >>> I believe Akka needs to allow acto

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

On 20.08.14 10:16, Roland Kuhn wrote: 19 aug 2014 kl. 18:59 skrev Ashley Aitken >: On Tuesday, 19 August 2014 21:14:17 UTC+8, rkuhn wrote: 18 aug 2014 kl. 18:01 skrev Ashley Aitken >: I believe Akka needs to allow actors to: (i) persist events wit

Re: [akka-user] Difference between PersistentView and Projections

It’s a naming thingy. PersistentView is our concrete implementation of "something that reads events given a persistenceId”. Current discussions involve making PersistentView more usable and powerful, as the current impl does not cover many use cases. Projections in general are simply “the read

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

19 aug 2014 kl. 18:59 skrev Ashley Aitken : > On Tuesday, 19 August 2014 21:14:17 UTC+8, rkuhn wrote: > > 18 aug 2014 kl. 18:01 skrev Ashley Aitken : > >> I believe Akka needs to allow actors to: >> >> (i) persist events with as much information as efficiently possible on the >> write side to

[akka-user] Difference between PersistentView and Projections

Team, I want to understand difference between PersistentView and Projections. I have gone through lot of posts on both these topics.How both differ in addressing querying/searching/Complex reporting in application. -Prakhyat M M -- >> Read the docs: http://akka.io/docs/ >

Re: [akka-user] Improving Akka Persistence wrt CQRS/ES/DDD

19 aug 2014 kl. 16:27 skrev Greg Young : > I am not responding to this one post just a reply towards the end and will > discuss a few posts from earlier. > > To start I have to agree with some of the posters that premature scaling can > cause many issues. This actually reminds me of the CQRS j

Re: [akka-user] Event Stores for Akka Persistence for CQRS?

Team, Consider I have domain model Bank Customer'*s* Account's Bank object will have many customers. Every customer will have multiple accounts. Consider I implement the above model using akka persistence. For the sake of discussion consider I make each as different Aggregate Roots using Pers