akka/akka — pull request #15486 by whiter4bbit (2014-07-03 01:06:54+00:00)
Title: RecoveryCompleted handled by receiveRecover

There is a little mistake in docs: RecoveryComplete is handled by receiveRecover, not by receiveCommand

class RecoveryTest extends PersistentActor with AtLeastOnceDelivery {
val log = Logging(context.system, this)
def receiveCommand = {
case RecoveryCompleted => log.info("Recovery completed in receiveCommand")
}
def receiveRecover = {
case RecoveryCompleted => log.info("Recovery completed in receiveRecover")
}
}

Prints:

[info] [INFO] [07/03/2014 04:05:35.170] [default-akka.actor.default-dispatcher-3] [akka://default/user/$a] Recovery complete in receiveRecover