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 <i...@holsman.com.au>:

> Thanks Matheus.
> That resolved the issue.
>
> Regards
> Ian
>
> On Thu, Nov 5, 2015 at 6:17 PM, <matheuslima...@gmail.com> 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
>>> i...@holsman.com.au
>>> 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 akka-user+unsubscr...@googlegroups.com.
>> To post to this group, send email to akka-user@googlegroups.com.
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> --
> Ian Holsman
> i...@holsman.com.au
> 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 akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
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