Add deprecated annotation to untyped APIs

src/main/scala/lerna/akka/entityreplication/ClusterReplication.scala

@@ -29,6 +29,7 @@ class ClusterReplication private (system: ExtendedActorSystem) extends Extension
   private[this] lazy val guardian: ActorRef =
     system.systemActorOf(ClusterReplicationGuardian.props(), "clusterReplicationGuardian")
 
+  @deprecated(message = "Use typed.ClusterReplication.init() instead", since = "2.0.0")
   def start(
       typeName: String,
       entityProps: Props,

src/main/scala/lerna/akka/entityreplication/ReplicationActor.scala

@@ -17,6 +17,7 @@ private[entityreplication] object ReplicationActor {
   private def generateInstanceId(): EntityInstanceId = EntityInstanceId(instanceIdCounter.getAndIncrement())
 }
 
+@deprecated(message = "Use typed.ReplicatedEntityBehavior instead", since = "2.0.0")
 trait ReplicationActor[StateData] extends Actor with Stash with akka.lerna.StashFactory {
   import context.dispatcher
 

src/main/scala/lerna/akka/entityreplication/testkit/TestReplicationActorProps.scala

@@ -6,6 +6,7 @@ import lerna.akka.entityreplication.ReplicationActor
 /**
   * The [[TestReplicationActorProps]] allows to test [[ReplicationActor]] like a normal Actor.
   */
+@deprecated(message = "Use typed.testkit.ReplicatedEntityBehaviorTestKit instead", since = "2.0.0")
 object TestReplicationActorProps {
 
   def apply(replicationActorProps: Props): Props = {

src/multi-jvm/scala/lerna/akka/entityreplication/ConsistencyTestBase.scala

@@ -4,6 +4,8 @@ import akka.remote.testconductor.RoleName
 import akka.remote.testkit.MultiNodeConfig
 import com.typesafe.config.ConfigFactory
 
+import scala.annotation.nowarn
+
 object ConsistencyTestBase {
 
   object ConsistencyTestBaseConfig extends MultiNodeConfig {
@@ -71,6 +73,7 @@ object ConsistencyTestBase {
     }
   }
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class ConsistencyTestReplicationActor() extends ReplicationActor[Int] {
 
     import ConsistencyTestReplicationActor._

src/multi-jvm/scala/lerna/akka/entityreplication/ConsistencyTestNormal.scala

@@ -1,11 +1,12 @@
 package lerna.akka.entityreplication
 
 import java.util.concurrent.atomic.AtomicInteger
-
 import akka.actor.{ ActorRef, Props }
 import akka.remote.testkit.MultiNodeSpec
 import lerna.akka.entityreplication.ConsistencyTestBase.{ ConsistencyTestBaseConfig, ConsistencyTestReplicationActor }
 import org.scalatest.Inside
+
+import scala.annotation.nowarn
 import scala.concurrent.duration._
 
 class ConsistencyTestNormalMultiJvmNode1 extends ConsistencyTestNormal
@@ -14,6 +15,7 @@ class ConsistencyTestNormalMultiJvmNode3 extends ConsistencyTestNormal
 class ConsistencyTestNormalMultiJvmNode4 extends ConsistencyTestNormal
 class ConsistencyTestNormalMultiJvmNode5 extends ConsistencyTestNormal
 
+@nowarn("msg=method start in class ClusterReplication is deprecated")
 class ConsistencyTestNormal extends MultiNodeSpec(ConsistencyTestBaseConfig) with STMultiNodeSpec with Inside {
 
   import ConsistencyTestBaseConfig._

src/multi-jvm/scala/lerna/akka/entityreplication/RaftActorCompactionSpec.scala

@@ -8,6 +8,7 @@ import lerna.akka.entityreplication.RaftActorCompactionSpec.DummyReplicationActo
 import lerna.akka.entityreplication.raft.protocol.SnapshotOffer
 
 import java.util.concurrent.atomic.AtomicInteger
+import scala.annotation.nowarn
 import scala.concurrent.duration._
 
 object RaftActorCompactionSpecConfig extends MultiNodeConfig {
@@ -23,9 +24,9 @@ object RaftActorCompactionSpecConfig extends MultiNodeConfig {
       .withFallback(ConfigFactory.parseString("""
       akka.actor.provider = cluster
       akka.test.single-expect-default = 15s
-      
+
       lerna.akka.entityreplication.raft.multi-raft-roles = ["replica-group-1", "replica-group-2", "replica-group-3"]
-      
+
       // triggers compaction each event replications
       lerna.akka.entityreplication.raft.compaction.log-size-threshold = 2
       lerna.akka.entityreplication.raft.compaction.preserve-log-size = 1
@@ -79,6 +80,7 @@ object RaftActorCompactionSpec {
 
   import DummyReplicationActor._
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class DummyReplicationActor extends ReplicationActor[State] {
 
     private[this] var state: State = State(0)
@@ -207,6 +209,7 @@ class RaftActorCompactionSpec extends MultiNodeSpec(RaftActorCompactionSpecConfi
     }
   }
 
+  @nowarn("msg=method start in class ClusterReplication is deprecated")
   def createReplication(typeName: String): ActorRef =
     planAutoKill {
       ClusterReplication(system).start(

src/multi-jvm/scala/lerna/akka/entityreplication/RaftEventSourcedSpec.scala

@@ -11,6 +11,7 @@ import com.typesafe.config.ConfigFactory
 import lerna.akka.entityreplication.raft.protocol.SnapshotOffer
 
 import java.util.concurrent.atomic.AtomicInteger
+import scala.annotation.nowarn
 
 object RaftEventSourcedSpecConfig extends MultiNodeConfig {
   val node1: RoleName = role("node1")
@@ -24,7 +25,7 @@ object RaftEventSourcedSpecConfig extends MultiNodeConfig {
       akka.test.single-expect-default = 15s
       lerna.akka.entityreplication.raft.multi-raft-roles = ["member-1", "member-2", "member-3"]
       lerna.akka.entityreplication.recovery-entity-timeout = 1s
-      
+
       inmemory-journal {
         event-adapters {
           dummy-event-adapter = "lerna.akka.entityreplication.RaftEventSourcedSpec$DummyEventAdapter"
@@ -91,6 +92,7 @@ object RaftEventSourcedSpec {
 
   import DummyReplicationActor._
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class DummyReplicationActor extends ReplicationActor[State] {
 
     private[this] var state: State = State(count = 0, knownRequestId = Set.empty)
@@ -150,6 +152,7 @@ object RaftEventSourcedSpec {
   }
 }
 
+@nowarn("msg=method start in class ClusterReplication is deprecated")
 class RaftEventSourcedSpec extends MultiNodeSpec(RaftEventSourcedSpecConfig) with STMultiNodeSpec {
 
   import RaftEventSourcedSpec._

src/multi-jvm/scala/lerna/akka/entityreplication/ReplicationActorMultiNodeSpec.scala

@@ -1,7 +1,6 @@
 package lerna.akka.entityreplication
 
 import java.util.concurrent.atomic.AtomicInteger
-
 import akka.{ Done, NotUsed }
 import akka.actor.{ ActorRef, PoisonPill, Props }
 import akka.cluster.Cluster
@@ -13,6 +12,7 @@ import com.typesafe.config.ConfigFactory
 import lerna.akka.entityreplication.raft.protocol.SnapshotOffer
 import lerna.akka.entityreplication.raft.routing.MemberIndex
 
+import scala.annotation.nowarn
 import scala.concurrent.duration._
 import scala.collection.Set
 
@@ -71,6 +71,7 @@ object ReplicationActorMultiNodeSpec {
     }
   }
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class PingPongReplicationActor extends ReplicationActor[Int] {
 
     import PingPongReplicationActor._
@@ -124,6 +125,7 @@ object ReplicationActorMultiNodeSpec {
     }
   }
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class LockReplicationActor extends ReplicationActor[NotUsed] {
     import LockReplicationActor._
 
@@ -183,6 +185,7 @@ object ReplicationActorMultiNodeSpec {
     }
   }
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class EphemeralReplicationActor extends ReplicationActor[Int] {
 
     import EphemeralReplicationActor._
@@ -220,6 +223,7 @@ class ReplicationActorMultiNodeSpecMultiJvmNode1 extends ReplicationActorMultiNo
 class ReplicationActorMultiNodeSpecMultiJvmNode2 extends ReplicationActorMultiNodeSpec
 class ReplicationActorMultiNodeSpecMultiJvmNode3 extends ReplicationActorMultiNodeSpec
 
+@nowarn("msg=method start in class ClusterReplication is deprecated")
 class ReplicationActorMultiNodeSpec extends MultiNodeSpec(ReplicationActorSpecConfig) with STMultiNodeSpec {
   import ReplicationActorMultiNodeSpec._
   import ReplicationActorSpecConfig._

src/multi-jvm/scala/lerna/akka/entityreplication/ReplicationRegionSpec.scala

@@ -14,6 +14,7 @@ import lerna.akka.entityreplication.raft.RaftProtocol.Command
 import lerna.akka.entityreplication.raft.protocol.SnapshotOffer
 import lerna.akka.entityreplication.raft.routing.MemberIndex
 
+import scala.annotation.nowarn
 import scala.concurrent.Future
 import scala.jdk.CollectionConverters._
 import scala.concurrent.duration._
@@ -47,6 +48,7 @@ object ReplicationRegionSpec {
     }
   }
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class DummyReplicationActor(probe: TestProbe) extends DiagnosticActorLogging with ReplicationActor[Int] {
 
     import DummyReplicationActor._
@@ -114,7 +116,7 @@ object ReplicationRegionSpecConfig extends MultiNodeConfig {
       .withFallback(ConfigFactory.parseString(s"""
       akka.actor.provider = cluster
       akka.test.single-expect-default = 15s
-      
+
       lerna.akka.entityreplication.raft.compaction.log-size-threshold = 2
       lerna.akka.entityreplication.raft.compaction.preserve-log-size = 1
       lerna.akka.entityreplication.raft.compaction.log-size-check-interval = 0.1s
@@ -176,6 +178,7 @@ class ReplicationRegionSpec extends MultiNodeSpec(ReplicationRegionSpecConfig) w
 
     val raftActorProbe = TestProbe("RaftActor")
 
+    @nowarn("msg=method start in class ClusterReplication is deprecated")
     def createReplication(typeName: String): ActorRef =
       planAutoKill {
         ClusterReplication(system).start(

src/test/scala/lerna/akka/entityreplication/ReplicationActorSpec.scala

@@ -8,7 +8,9 @@ import lerna.akka.entityreplication.ReplicationActorSpec.{ config, ExampleReplic
 import lerna.akka.entityreplication.model.EntityInstanceId
 import lerna.akka.entityreplication.raft.model.{ EntityEvent, LogEntry, LogEntryIndex, Term }
 import lerna.akka.entityreplication.raft.{ ActorSpec, RaftProtocol }
+
 import java.util.concurrent.atomic.AtomicInteger
+import scala.annotation.nowarn
 
 object ReplicationActorSpec {
 
@@ -29,6 +31,7 @@ object ReplicationActorSpec {
     case class Counted() extends Event
   }
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class ExampleReplicationActor extends ReplicationActor[Int] {
     import ExampleReplicationActor._
 

src/test/scala/lerna/akka/entityreplication/testkit/TestReplicationActorPropsSpec.scala

@@ -6,6 +6,8 @@ import lerna.akka.entityreplication.{ ReplicationActor, ReplicationRegion }
 import lerna.akka.entityreplication.testkit.TestReplicationActorPropsSpec.WordCountReplicationActor
 import org.scalatest.{ Matchers, WordSpecLike }
 
+import scala.annotation.nowarn
+
 object TestReplicationActorPropsSpec {
 
   object WordCountReplicationActor {
@@ -22,6 +24,7 @@ object TestReplicationActorPropsSpec {
     final case class Counted(wordCount: Int) extends DomainEvent
   }
 
+  @nowarn("msg=Use typed.ReplicatedEntityBehavior instead")
   class WordCountReplicationActor extends ReplicationActor[Int] {
     import WordCountReplicationActor._
 
@@ -54,6 +57,7 @@ object TestReplicationActorPropsSpec {
   }
 }
 
+@nowarn("msg=Use typed.testkit.ReplicatedEntityBehaviorTestKit instead")
 class TestReplicationActorPropsSpec extends TestKit(ActorSystem()) with WordSpecLike with Matchers with ImplicitSender {
   import WordCountReplicationActor._