I've had a similar problem during creation of some multi node tests using leveldb as storage. The leveldb was misconfigured and my persistent actors crashed silently...
Em sexta-feira, 6 de novembro de 2015 02:58:43 UTC-3, Patrik Nordwall escreveu: > > Didn't you see anything in the logs? I'm asking because if it is silent it > is something we must improve. > > /Patrik > fre 6 nov. 2015 kl. 01:28 skrev Ian Holsman <[email protected] > <javascript:>>: > >> Thanks Matheus. >> That resolved the issue. >> >> Regards >> Ian >> >> On Thu, Nov 5, 2015 at 6:17 PM, <[email protected] <javascript:>> >> wrote: >> >>> I guess the problem is how you are setting the persistence plugin: >>> Try change it: >>> >>> >>> - akka.persistence.journal.plugin = "leveldb" -> >>> >>> - akka.persistence.journal.plugin = "akka.persistence.journal.leveldb" >>> >>> >>> >>> >>> - akka.persistence.snapshot-store.plugin = "leveldb" -> >>> >>> >>> - akka.persistence.snapshot-store.plugin = >>> "akka.persistence.snapshot-store.local" >>> >>> >>> I don't know if leveldb has a snapshot plugin... >>> By the way, in my experience, issues with send message to persistent >>> actor normally are associated with persistence plugin settings. The actor >>> cannot be initialized if there is problems with persistence. >>> >>> >>> On Thursday, November 5, 2015 at 11:07:27 PM UTC, Ian Holsman wrote: >>> >>>> Hi. >>>> >>>> I'm having a bit of trouble at the moment, and I think it's due to me >>>> upgrading to most recent versions of things. >>>> >>>> I was on 2.3.11 of akka & akka-persistence-experimental , and using >>>> 1.0-RC3 of akka-http. >>>> >>>> I'm now on 2.4.0 / 1.0 respectively. >>>> >>>> I had to change the code (minor) due to syntax changes but I don't feel >>>> it is that. >>>> I also had to add a leveldb configuration area in application.conf >>>> which i'm guessing is the issue. >>>> >>>> fwiw the actor works as a 'regular' actor in terms of actually >>>> receiving the message .. this is my actor code.. (it should just print out >>>> something but it doesn't). >>>> >>>> class VillageManager(nameGenerator:String) extends PersistentActor with >>>> ActorLogging { >>>> override def persistenceId: String = s"village-manager" >>>> override def receiveRecover: Receive = { >>>> case _ => log.error("VillageMgr - unknown") >>>> } >>>> override def receiveCommand: Receive = { >>>> case _ => >>>> println("in Actor") >>>> log.error("Undefined message") >>>> } >>>> } >>>> >>>> object VillageManager { >>>> def props(nameGen: String): Props = Props(classOf[VillageManager], >>>> nameGen) >>>> } >>>> >>>> >>>> my application.conf is >>>> >>>> akka { >>>> log-dead-letters = 10 >>>> log-dead-letters-during-shutdown = on >>>> >>>> persistence { >>>> snapshot-store { >>>> plugin = "leveldb" >>>> local.dir = "target/persistence/snapshots" >>>> } >>>> >>>> journal { >>>> plugin = "leveldb" >>>> leveldb { >>>> dir = "target/persistence/journal" >>>> native = true >>>> } >>>> } >>>> } >>>> } >>>> >>>> leveldb { >>>> dir = "target/persistence/journal" >>>> checksum: "off" >>>> class: "akka.persistence.journal.leveldb.LeveldbJournal" >>>> dir: "target/persistence/journal" >>>> fsync: "on" >>>> native: "on" >>>> plugin-dispatcher : >>>> "akka.persistence.dispatchers.default-plugin-dispatcher" >>>> replay-dispatcher : >>>> "akka.persistence.dispatchers.default-replay-dispatcher" >>>> } >>>> >>>> my build.sbt is: >>>> >>>> import sbt.Keys._ >>>> >>>> name := "projectName" >>>> >>>> version := "1.0" >>>> >>>> scalaVersion := "2.11.7" >>>> >>>> resolvers += "Typesafe Repository" at >>>> "http://repo.typesafe.com/typesafe/releases/"; >>>> >>>> resolvers += "bintray/meetup" at "http://dl.bintray.com/meetup/maven"; >>>> >>>> val akkaVersion = "2.4.0" >>>> val akkaStream = "1.0" >>>> >>>> scalacOptions ++= Seq("-unchecked", "-deprecation", "-feature") >>>> libraryDependencies ++= Seq( >>>> "com.typesafe.akka" %% "akka-actor" % akkaVersion, >>>> "com.typesafe.akka" %% "akka-testkit" % akkaVersion % "test", >>>> "com.typesafe.akka" %% "akka-persistence" % akkaVersion, >>>> "com.typesafe.akka" % "akka-http-core-experimental_2.11" % akkaStream, >>>> "com.typesafe.akka" % "akka-http-experimental_2.11" % akkaStream, >>>> "com.typesafe.akka" % "akka-stream-experimental_2.11" % akkaStream, >>>> "io.jvm.uuid" %% "scala-uuid" % "0.2.1", >>>> "com.fasterxml.jackson.module" %% "jackson-module-scala" % "2.6.1", >>>> "org.scalatest" %% "scalatest" % "2.2.5", >>>> "junit" % "junit" % "4.12" % "test", >>>> "org.iq80.leveldb" % "leveldb" % "0.7", >>>> "org.fusesource.leveldbjni" % "leveldbjni-all" % "1.8", >>>> "com.meetup" %% "archery" % "0.4.0" >>>> ) >>>> >>>> >>>> lazy val root = (project in file(".")).enablePlugins(SbtTwirl) >>>> >>>> >>>> I'm at a loss on how to debug this. >>>> >>>> >>>> -- >>>> Ian Holsman >>>> [email protected] >>>> PH: + 61-3-9028 8133 / +1-(425) 998-7083 >>>> >>> -- >>> >>>>>>>>>> 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] <javascript:>. >>> To post to this group, send email to [email protected] >>> <javascript:>. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Ian Holsman >> [email protected] <javascript:> >> PH: + 61-3-9028 8133 / +1-(425) 998-7083 >> >> -- >> >>>>>>>>>> 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] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > -- >>>>>>>>>> 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.
