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].
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.
