fix akka-cluster-tools compile error
This commit is contained in:
parent
28b86379c8
commit
502ff08df5
1 changed files with 2 additions and 2 deletions
|
|
@ -23,7 +23,7 @@ import scala.collection.immutable
|
||||||
import java.util.concurrent.ConcurrentHashMap
|
import java.util.concurrent.ConcurrentHashMap
|
||||||
|
|
||||||
import akka.remote.DefaultFailureDetectorRegistry
|
import akka.remote.DefaultFailureDetectorRegistry
|
||||||
import akka.cluster.ClusterEvent.{ CurrentClusterState, MemberEvent, MemberExited, MemberRemoved }
|
import akka.cluster.ClusterEvent.{ MemberEvent, MemberRemoved }
|
||||||
|
|
||||||
import scala.concurrent.Await
|
import scala.concurrent.Await
|
||||||
|
|
||||||
|
|
@ -95,7 +95,7 @@ object MultiNodeClusterSpec {
|
||||||
|
|
||||||
trait MultiNodeClusterSpec extends Suite with STMultiNodeSpec with WatchedByCoroner with FlightRecordingSupport { self: MultiNodeSpec ⇒
|
trait MultiNodeClusterSpec extends Suite with STMultiNodeSpec with WatchedByCoroner with FlightRecordingSupport { self: MultiNodeSpec ⇒
|
||||||
|
|
||||||
final override def initialParticipants = roles.size
|
override def initialParticipants = roles.size
|
||||||
|
|
||||||
private val cachedAddresses = new ConcurrentHashMap[RoleName, Address]
|
private val cachedAddresses = new ConcurrentHashMap[RoleName, Address]
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue