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

2.13 compilation

Browse source
This commit is contained in:
Christopher Batey 2020-08-17 10:04:43 +01:00
parent 9ba9571b4a
commit 90e09549e8
2 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/ReplicatedShardingSpec.scala
View file

@ -35,7 +35,8 @@ import akka.cluster.sharding.typed.ReplicatedShardingSpec.MyReplicatedIntSet
import akka.cluster.sharding.typed.ReplicatedShardingSpec.MyReplicatedStringSet
import akka.persistence.typed.ReplicationId
import com.typesafe.config.Config
import akka.util.ccompat._
@ccompatUsedUntil213
object ReplicatedShardingSpec {
def commonConfig = ConfigFactory.parseString("""
akka.loglevel = INFO
@ -247,12 +248,12 @@ abstract class ReplicatedShardingSpec(replicationType: ReplicationType, configA:
Cluster(system2).manager ! Join(Cluster(system).selfMember.address)
eventually {
Cluster(system).state.members.size should ===(2)
Cluster(system).state.members.map(_.status) should ===(Set[MemberStatus](MemberStatus.Up))
Cluster(system).state.members.unsorted.size should ===(2)
Cluster(system).state.members.unsorted.map(_.status) should ===(Set[MemberStatus](MemberStatus.Up))
}
eventually {
Cluster(system2).state.members.size should ===(2)
Cluster(system2).state.members.map(_.status) should ===(Set[MemberStatus](MemberStatus.Up))
Cluster(system2).state.members.unsorted.size should ===(2)
Cluster(system2).state.members.unsorted.map(_.status) should ===(Set[MemberStatus](MemberStatus.Up))
}
}

2
akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/TestKitStorage.scala
View file

@ -8,7 +8,7 @@ import java.util.concurrent.ConcurrentHashMap
import java.util.concurrent.atomic.AtomicReference
import scala.collection.immutable
import scala.collection.JavaConverters._
import akka.util.ccompat.JavaConverters._
import akka.annotation.InternalApi
import akka.persistence.testkit.ProcessingPolicy