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

ENT-6743: Reverted RetryFlowMockTest as the retry op only available on ENT.

Browse Source
This commit is contained in:
Adel El-Beik 2022-04-25 11:30:24 +01:00
parent fa607024c2
commit c1002697c7
1 changed files with 0 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
node/src/test/kotlin/net/corda/node/services/statemachine/RetryFlowMockTest.kt
View File

@ -6,7 +6,6 @@ import net.corda.core.flows.Destination
import net.corda.core.flows.FlowInfo
import net.corda.core.flows.FlowLogic
import net.corda.core.flows.FlowSession
import net.corda.core.flows.HospitalizeFlowException
import net.corda.core.flows.InitiatedBy
import net.corda.core.flows.InitiatingFlow
import net.corda.core.flows.KilledFlowException
@ -30,7 +29,6 @@ import net.corda.testing.node.internal.MessagingServiceSpy
import net.corda.testing.node.internal.TestStartedNode
import net.corda.testing.node.internal.enclosedCordapp
import net.corda.testing.node.internal.newContext
import net.corda.testing.node.internal.startFlow
import org.assertj.core.api.Assertions.assertThat
import org.assertj.core.api.Assertions.assertThatExceptionOfType
import org.h2.util.Utils
@ -49,7 +47,6 @@ import java.util.concurrent.Semaphore
import java.util.concurrent.TimeUnit
import kotlin.test.assertEquals
import kotlin.test.assertFailsWith
import kotlin.test.assertFalse
import kotlin.test.assertNotNull
import kotlin.test.assertNull
@ -327,25 +324,6 @@ class RetryFlowMockTest {
}
}
class HospitalizeThenSucceedFlow : FlowLogic<Boolean>() {
companion object {
var runs = 0
var flowRetried = Semaphore(0)
var flowWillReturn = Semaphore(0)
}
@Suspendable
override fun call(): Boolean {
if (runs == 0) {
runs++
throw HospitalizeFlowException("Hospitalize on first run")
}
flowRetried.release()
flowWillReturn.acquire()
return true
}
}
@InitiatingFlow
class UnbalancedSendAndReceiveFlow(private val other: Party) : FlowLogic<Unit>() {