Hi Mike,
The problem is you have not performed a 1:1 migration, instead you ended up
using what was previously known as EventsourcedProcessor, but you expected
to use "the new Processor".

Using persist + PersistentActor, which is equivalent to the previous persist
in EventsourcedProcessor.
Since you are migrating from persist + Processor, you should migrate to
it’s equivalent: persistAsync.

Please check the migration guide where this is explained:
http://doc.akka.io/docs/akka/2.3.4/project/migration-guide-persistence-experimental-2.3.x-2.4.x.html#removed-processor-in-favour-of-extending-persistentactor-with-persistasync

PersistentActor + persistAsync in 2.3.4 == Processor in 2.3.3.
PersistentActor + persist in 2.3.4 == EventsourcedProcessor in 2.3.3, it
will be by definition slower than persistAsync, because of stronger
guarantees it delivers.


Here are the benchmark results (Intel(R) Core(TM) i7-4850HQ CPU @ 2.30GHz,
LevelDB), from the JMH bench I linked to previously, as you’ll notice
PersistentActor#persistAsync is on par with Processor#persist:

[info] Benchmark
                                   Mode   Samples        Score  Score
error    Units
[info] a.p.PersistentActorThroughputBenchmark.actor_*normalActor_reply_baseline*
                          thrpt        10   147567.305     4617.027
ops/s
[info] a.p.PersistentActorThroughputBenchmark.persistentActor_noPersist_reply
                           thrpt        10   147099.384     6547.412
 ops/s
[info] a.p.PersistentActorThroughputBenchmark.processor_noPersist_reply
                                 thrpt        10    45720.023
1850.406    ops/s[info]
a.p.PersistentActorThroughputBenchmark.persistentActor_persistAsync_replyRightOnCommandReceive
   thrpt        10   116179.339    41959.652    ops/s
[info] 
a.p.PersistentActorThroughputBenchmark.*persistentActor_persistAsync_reply
                        thrpt        10    28391.199      647.556
ops/s*
[info] a.p.PersistentActorThroughputBenchmark.*processor_persist_reply*
          *                         thrpt        10    26594.156
586.717    ops/s

*[info] a.p.PersistentActorThroughputBenchmark.persistentActor_persist_reply
                             thrpt        10     4696.254      104.952
   ops/s

​

Change your code to use persistAsync && happy hakking!

-- 
Cheers,
Konrad 'ktoso' Malawski
hAkker @ Typesafe

<http://typesafe.com>

-- 
>>>>>>>>>>      Read the docs: http://akka.io/docs/
>>>>>>>>>>      Check the FAQ: 
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>>      Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Reply via email to