ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-15 01:10:33 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

30 seconds timeout on notary health check

Browse Source
This commit is contained in:
Thomas Schroeter 2018-01-25 15:19:14 +00:00 committed by Andrius Dagys
parent 1b2d7b3f1f
commit 794a7b0d51
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tools/notaryhealthcheck/src/main/kotlin/net/corda/notaryhealthcheck/Main.kt
View File

@ -7,6 +7,7 @@ import net.corda.core.utilities.NetworkHostAndPort
import net.corda.nodeapi.internal.config.User import net.corda.nodeapi.internal.config.User
import net.corda.node.services.Permissions import net.corda.node.services.Permissions
import net.corda.notaryhealthcheck.flows.HealthCheckFlow import net.corda.notaryhealthcheck.flows.HealthCheckFlow
import java.util.concurrent.TimeUnit
fun main(args: Array<String>) { fun main(args: Array<String>) {
val addresses = listOf(NetworkHostAndPort("localhost", 10003)) val addresses = listOf(NetworkHostAndPort("localhost", 10003))
@ -22,6 +23,6 @@ fun main(args: Array<String>) {
fun healthCheck(rpc: CordaRPCOps) { fun healthCheck(rpc: CordaRPCOps) {
val notary = rpc.notaryIdentities().first() val notary = rpc.notaryIdentities().first()
print("Running health check for notary cluster ${notary.name}... ") print("Running health check for notary cluster ${notary.name}... ")
rpc.startFlow(::HealthCheckFlow, notary, true).returnValue.get() rpc.startFlow(::HealthCheckFlow, notary, true).returnValue.get(30, TimeUnit.SECONDS)
println("Done.") println("Done.")
} }