Package net.corda.client.rpc.proxy

val rpcAddress = NetworkHostAndPort("nodeAddress", 1000)
val client = MultiRPCClient(rpcAddress, NodeFlowStatusRpcOps::class.java, rpcUser.username, rpcUser.password)
val connFuture = client.start()
val conn = connFuture.get()
val flowStatusRPCOPs = conn.proxy

val matchingFlows: List<String>  = flowStatusRPCOPs.getFlowsMatching(FlowStatusQuery(
flowClass = "IssueToken",
flowState = FlowState.RUNNABLE,
progressStep = "SIGNING",
cordapp = "tokens-workflows",
compatibleWithCurrentCordaRuntime = true,
suspensionDuration = Duration.ofMinutes(10),
flowStart = FlowTimeWindow.between(Instant.now().minus(30, ChronoUnit.MINUTES), Instant.now())
)
)
matchingFlows.forEach { flowId ->
println(flowStatusRPCOPs.getFlowStatus(flowId))
}

val rpcAddress = NetworkHostAndPort("nodeAddress", 1000)
val client = MultiRPCClient(rpcAddress, NodeFlowStatusRpcOps::class.java, rpcUser.username, rpcUser.password)
val connFuture = client.start()
val conn = connFuture.get()
val nodeStatusRPCOPs = conn.proxy

println(nodeStatusRPCOPs.getConfigAsHOCONString())
}