Hi,
I have this leveldb journal problem when playing with the new persistence
module. With this simple setup:
class ProcActor extends Processor {
override def receive = {
case Persistent(_, sequenceNr) =>
deleteMessages(sequenceNr)
}
}
object Main extends App {
implicit lazy val system = ActorSystem("evsourd",
ConfigFactory.load().getConfig("evsourd"))
val top = system.actorOf(Props[ProcActor], name = "top")
for(i <- 1 to 1000000)
top ! Persistent(i)
}
why does my leveldb journal directory (default, native leveldb) grows to
over 1 Gb within minutes? Aren't all messages are deleted by ProcActor?
Also - is there any way to look into what's in the journal?
Thanks
Vadim
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ: http://akka.io/faq/
>>>>>>>>>> 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/groups/opt_out.
