[akka-user] Distributed Data - OversizedPayloadException even when splitting ORMultiMap into many keys

2017-08-01 Thread Yee-Ning Cheng
Hi, I currently am using using ~100 instances of ORMultiMap[Int, Int] by the following code and am constantly adding/deleting elements (~200/sec) in the value sets. I have delta-crdt enabled as well. def hash(key: Int, mod: Int) = { key % mod } def mapKey(key: Int) = { ORMultiMapKey[Int,

Re: [akka-user] Permanently stopping a persisted single entity in a cluster shard

2017-06-06 Thread Yee-Ning Cheng
, but I'm not sure how else it could work -- > you're presuming magic central knowledge that a particular Entity is > "permanently dead", and that's not a concept that exists in Cluster > Sharding. If you want to smash an entity flat permanently, such that it

[akka-user] Permanently stopping a persisted single entity in a cluster shard

2017-06-06 Thread Yee-Ning Cheng
I currently have an actor that extends PersistentActor and is created using cluster sharding as a single entity part of a shard. After a certain amount of time, I want to be able to explicity kill/stop a single entity actor permanently. I have tried using Passivate, explicitly sending a Poiso