raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Harden PersistentShardingMigrationSpec (#29240)

Browse source 
Wait for cluster to be up before running test and increase retry
interval
This commit is contained in:
Christopher Batey 2020-06-16 09:49:46 +01:00 • committed by GitHub
parent b2b594293d
commit 395fa64f8c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-cluster-sharding/src/test/scala/akka/cluster/sharding/PersistentShardingMigrationSpec.scala
View file

@ -6,7 +6,7 @@ package akka.cluster.sharding
import java.util.UUID
import akka.actor.{ ActorRef, ActorSystem, Props }
import akka.cluster.Cluster
import akka.cluster.{ Cluster, MemberStatus }
import akka.persistence.PersistentActor
import akka.testkit.{ AkkaSpec, ImplicitSender, TestProbe }
import com.typesafe.config.{ Config, ConfigFactory }
@ -36,6 +36,9 @@ object PersistentShardingMigrationSpec {
snapshot-after = 5
verbose-debug-logging = on
# Lots of sharding setup, make it quicker
retry-interval = 500ms
}
akka.persistence.journal.plugin = "akka.persistence.journal.leveldb"
@ -142,17 +145,19 @@ class PersistentShardingMigrationSpec extends AkkaSpec(PersistentShardingMigrati
}
}
withSystem(config, typeName, "OldMode") { (system, region, _) =>
withSystem(config, typeName, "OldModeShouldNotWork") { (system, region, _) =>
val probe = TestProbe()(system)
region.tell(Message(1), probe.ref)
probe.expectNoMessage(2.seconds)
probe.expectNoMessage(1.seconds)
}
}
def withSystem(config: Config, typeName: String, systemName: String)(
f: (ActorSystem, ActorRef, TestProbe) => Unit) = {
val system = ActorSystem(systemName, config)
Cluster(system).join(Cluster(system).selfAddress)
val cluster = Cluster(system)
cluster.join(cluster.selfAddress)
awaitAssert(cluster.selfMember.status shouldEqual MemberStatus.Up)
try {
val rememberedEntitiesProbe = TestProbe()(system)
val region = ClusterSharding(system).start(