From af0c45b287db6e0ce7fe7faf48b08205f0cdfb7e Mon Sep 17 00:00:00 2001 From: szymonsztuka Date: Thu, 20 Sep 2018 20:19:35 +0100 Subject: [PATCH] Added required terminate and isWaitingForShutdown methods by CordaRPCOps. --- .../main/kotlin/net/corda/rpcWorker/CordaRpcWorkerOps.kt | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/experimental/rpc-worker/src/main/kotlin/net/corda/rpcWorker/CordaRpcWorkerOps.kt b/experimental/rpc-worker/src/main/kotlin/net/corda/rpcWorker/CordaRpcWorkerOps.kt index 58df572ebd..745216d8e4 100644 --- a/experimental/rpc-worker/src/main/kotlin/net/corda/rpcWorker/CordaRpcWorkerOps.kt +++ b/experimental/rpc-worker/src/main/kotlin/net/corda/rpcWorker/CordaRpcWorkerOps.kt @@ -338,6 +338,14 @@ class CordaRpcWorkerOps( shutdownNode.invoke() } + override fun terminate(drainPendingFlows: Boolean) { + TODO("not implemented") + } + + override fun isWaitingForShutdown(): Boolean { + TODO("not implemented") + } + private fun stateMachineInfoFromFlowLogic(flowLogic: FlowLogic<*>): StateMachineInfo { return StateMachineInfo(flowLogic.runId, flowLogic.javaClass.name, flowLogic.stateMachine.context.toFlowInitiator(), flowLogic.track(), flowLogic.stateMachine.context) }