Fix HealthCheckFlow to work with distributed notaries

This commit is contained in:
Andras Slemmer 2018-02-20 18:00:59 +00:00
parent a6a2008bb9
commit 1027b0e49c

View File

@ -28,9 +28,7 @@ class HealthCheckNotaryClientFlow(
val notaryParty = checkTransaction() val notaryParty = checkTransaction()
val parties = if (checkEntireCluster) { val parties = if (checkEntireCluster) {
serviceHub.networkMapCache serviceHub.networkMapCache.notaryIdentities.filter { it.owningKey == notaryParty.owningKey }
.getNodesByLegalIdentityKey(notaryParty.owningKey)
.map { it.legalIdentities.first() }
} else { } else {
listOf(notaryParty) listOf(notaryParty)
} }