diff --git a/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/internal/HakkerTracker.scala b/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/internal/HakkerTracker.scala index 04d19182fd..60926051de 100644 --- a/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/internal/HakkerTracker.scala +++ b/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/internal/HakkerTracker.scala @@ -1,6 +1,6 @@ package akka.sample.osgi.internal -import akka.persistence.EventsourcedProcessor +import akka.persistence.PersistentActor import akka.actor.ActorRef import akka.sample.osgi.api.HakkerStateChange import akka.sample.osgi.api.SubscribeToHakkerStateChanges @@ -27,11 +27,13 @@ object HakkerTracker { } } -class HakkerTracker extends EventsourcedProcessor { +class HakkerTracker extends PersistentActor { import HakkerTracker._ var state = State.empty + override def persistenceId: String = "hakkerTracker" + override def receiveRecover: Receive = { case evt: DomainEvent => state = state.updated(evt)