I'm attempting to write a persistence plugin that saves in JSON format
into flat files. I've got the basic write side working but I'm seeing
records in the JSON file with duplicate sequenceNr values
(PersistentRepr.sequenceNr). My test harness is creating two instances
of the same PersistentAct
It is unsafe to have 2 writers at the same time in Akka Persistence.
All tools around it, such as Cluster Sharding etc work towards ensuring
that you always have the one single entity existing, and not two entities
of the same identity.
If you think about it as in modeling any domain, that is exac
On 27/01/17 10:59, Konrad Malawski wrote:
So the uniequeness is to be guarnateed on persistentId. The writerUID
exists for noticing that things are going wrong / have gone wrong and
restoring from such failures. It is wrong to write tests that have 2
writers and expect a consistent output "just
Not "ever", but "at the same time". This is exactly the single writer
principle.
Otherwise you would have to check the entire cluster before each write
making sure that there wasn't a conflicting write ;) there's quite some
theory behind this. As I mentioned, CRDTs take the oppsosite stance.
Pleas
On 27/01/17 11:36, Konrad Malawski wrote:
Not "ever", but "at the same time". This is exactly the single
writer principle. Otherwise you would have to check the entire
cluster before each write making sure that there wasn't a conflicting
write ;) there's quite some theory behind this. As I menti
Thanks for the reply! I'm currently implemented some plain and simple
observable variable model atop of normal actors. Actor could control
immutable state, it accepts update messages that contains write lenses and
applies them. It manages subscriptions to the changes where subscriber
provide re
Hi!
Is there any way to deploy the code (jar files) along with starting the new
actors in the Akka cluster without the cluster restart? For example - I
have some "base" actors tier that provides the core logic for the data
flow.
Now I want to create a solution, that will use these actors (usi
