No messages received in receiveRecover

[lilZ420]

During recovery (ex: restarting the actor), I am not getting any of the messages replayed. I am immediately just receiving RecoveryComplete. Any ideas?

Code example:

val receiveRecover: Receive = {
    case message: MyMessageType => println(message) // never receive this
    case recoveryComplete: RecoveryCompleted => // receive this immediately
    case _ => println("Unhandled message") // never receive this
}

Thanks in advance.

[drexin]

Just pushed some changes. Commit after every insert, newer version of MapDB and Akka. Hope this helps.

[lilZ420]

I pulled your changes but I'm getting this error during recovery now:

java.lang.RuntimeException: Could not instantiate class
at org.mapdb.SerializerPojo.deserializeUnknownHeader(SerializerPojo.java:483)
at org.mapdb.SerializerBase.deserialize3(SerializerBase.java:1216)
at org.mapdb.SerializerBase.deserialize(SerializerBase.java:1132)
at org.mapdb.SerializerBase.deserialize(SerializerBase.java:867)
at org.mapdb.SerializerPojo.deserialize(SerializerPojo.java:701)
at org.mapdb.BTreeMap$NodeSerializer.deserialize(BTreeMap.java:449)
at org.mapdb.BTreeMap$NodeSerializer.deserialize(BTreeMap.java:288)
at org.mapdb.Store.deserialize(Store.java:297)
at org.mapdb.StoreDirect.get2(StoreDirect.java:475)
at org.mapdb.StoreWAL.get2(StoreWAL.java:368)
at org.mapdb.StoreWAL.get(StoreWAL.java:352)
at org.mapdb.EngineWrapper.get(EngineWrapper.java:58)
at org.mapdb.Caches$LRU.get(Caches.java:84)
at org.mapdb.EngineWrapper.get(EngineWrapper.java:58)
at org.mapdb.BTreeMap.<init>(BTreeMap.java:541)
at org.mapdb.DB.getTreeMap(DB.java:788)
at akka.persistence.journal.mapdb.MapDBJournal.messagesMap(MapDBJournal.scala:76)
at akka.persistence.journal.mapdb.MapDBRecovery$$anonfun$asyncReplayMessages$1.apply$mcV$sp(MapDBRecovery.scala:17)
at akka.persistence.journal.mapdb.MapDBRecovery$$anonfun$asyncReplayMessages$1.apply(MapDBRecovery.scala:14)
at akka.persistence.journal.mapdb.MapDBRecovery$$anonfun$asyncReplayMessages$1.apply(MapDBRecovery.scala:14)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.RuntimeException: Could not instantiate class
at org.mapdb.SerializerPojo.deserializeUnknownHeader(SerializerPojo.java:483)
at org.mapdb.SerializerBase.deserialize3(SerializerBase.java:1216)
at org.mapdb.SerializerBase.deserialize(SerializerBase.java:1132)
at org.mapdb.SerializerPojo.deserializeUnknownHeader(SerializerPojo.java:477)
... 25 more
Caused by: java.lang.IllegalStateException: Trying to deserialize a serialized ActorRef without an ActorSystem in scope. Use 'akka.serialization.Serialization.currentSystem.withValue(system) { ... }'
at akka.actor.SerializedActorRef.readResolve(ActorRef.scala:407)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1104)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1807)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
at org.mapdb.SerializerPojo.deserializeUnknownHeader(SerializerPojo.java:461)
... 28 more

[markfennema]

I'm running into the same problem, did you find out what was causing it?

Thanks.

[lilZ420]

I was never able to determine the cause or find a solution for the issue. I ended up just sticking with the LevelDB implementation.

[drexin]

Hi, unfortunately I don't have any time to look into this. This project is not up to date, so I think it shouldn't be used.