From 8e6ae061bfb0fa308be1db78606bba540d9df70e Mon Sep 17 00:00:00 2001
From: Shams Asari <shams.asari@r3cev.com>
Date: Tue, 22 Nov 2016 18:18:06 +0000
Subject: [PATCH] Fix incorrect protocol references

---
 .../kotlin/net/corda/client/CordaRPCClientTest.kt    | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/client/src/integration-test/kotlin/net/corda/client/CordaRPCClientTest.kt b/client/src/integration-test/kotlin/net/corda/client/CordaRPCClientTest.kt
index 0e8bf05453..153851bf53 100644
--- a/client/src/integration-test/kotlin/net/corda/client/CordaRPCClientTest.kt
+++ b/client/src/integration-test/kotlin/net/corda/client/CordaRPCClientTest.kt
@@ -4,16 +4,16 @@ import net.corda.core.contracts.DOLLARS
 import net.corda.core.node.services.ServiceInfo
 import net.corda.core.random63BitValue
 import net.corda.core.serialization.OpaqueBytes
+import net.corda.flows.CashCommand
+import net.corda.flows.CashFlow
 import net.corda.node.driver.NodeInfoAndConfig
 import net.corda.node.driver.driver
 import net.corda.node.services.User
 import net.corda.node.services.config.configureTestSSL
 import net.corda.node.services.messaging.ArtemisMessagingComponent.Companion.toHostAndPort
-import net.corda.node.services.messaging.startProtocol
-import net.corda.node.services.startProtocolPermission
+import net.corda.node.services.messaging.startFlow
+import net.corda.node.services.startFlowPermission
 import net.corda.node.services.transactions.ValidatingNotaryService
-import net.corda.protocols.CashCommand
-import net.corda.protocols.CashProtocol
 import org.apache.activemq.artemis.api.core.ActiveMQSecurityException
 import org.assertj.core.api.Assertions.assertThatExceptionOfType
 import org.junit.After
@@ -24,7 +24,7 @@ import kotlin.concurrent.thread
 
 class CordaRPCClientTest {
 
-    private val rpcUser = User("user1", "test", permissions = setOf(startProtocolPermission<CashProtocol>()))
+    private val rpcUser = User("user1", "test", permissions = setOf(startFlowPermission<CashFlow>()))
     private val stopDriver = CountDownLatch(1)
     private var driverThread: Thread? = null
     private lateinit var client: CordaRPCClient
@@ -76,7 +76,7 @@ class CordaRPCClientTest {
         println("Creating proxy")
         val proxy = client.proxy()
         println("Starting protocol")
-        val protocolHandle = proxy.startProtocol(::CashProtocol, CashCommand.IssueCash(20.DOLLARS, OpaqueBytes.of(0), driverInfo.nodeInfo.legalIdentity, driverInfo.nodeInfo.legalIdentity))
+        val protocolHandle = proxy.startFlow(::CashFlow, CashCommand.IssueCash(20.DOLLARS, OpaqueBytes.of(0), driverInfo.nodeInfo.legalIdentity, driverInfo.nodeInfo.legalIdentity))
         println("Started protocol, waiting on result")
         protocolHandle.progress.subscribe {
             println("PROGRESS $it")