Hi folks,
I'm wondering whether *journal.max-message-batch-size* should be used to
batch events passed to *persist() *method ?
It is ignored now, is it expected?
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Hi Yaroslav!
What do you mean?
It is applied - we flush a write when the accumulated events reach lenght of
that configured setting:
eventBatch.reverse.foreach { p ⇒
addToBatch(p)
if (!writeInProgress || maxBatchSizeReached) flushJournalBatch()
If you mean the persistAll(Seq()) than that's
I'm talking about `final def persist[A](events: immutable.Seq[A])(handler: A
⇒ Unit): Unit` in Akka 2.3
Looks like this has been fixed in Akka 2.4, thanks Konrad.
On Monday, July 27, 2015 at 11:48:04 AM UTC+3, Konrad Malawski wrote:
Hi Yaroslav!
What do you mean?
It is applied - we flush
persist(Seq) is == persistAll(Seq) in 2.4.x, with persist(Seq) being deprecated.
Thanks for the due diligence!
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 27 July 2015 at 10:59:56, Yaroslav Klymko (t3h...@gmail.com) wrote:
I'm talking about `final def persist[A](events:
