gevamu-payment-workflows/com.gevamu.corda.flows/SendPaymentFlow

SendPaymentFlow

@InitiatingFlow

@StartableByService

class SendPaymentFlow(uniquePaymentId: UUID) : FlowLogic<Unit>

Constructors

SendPaymentFlow

fun SendPaymentFlow(uniquePaymentId: UUID)

Functions

await

fun <R : Any> await(operation: FlowExternalAsyncOperation<R>): R

fun <R : Any> await(operation: FlowExternalOperation<R>): R

call

@Suspendable

open override fun call()

checkFlowIsNotKilled

fun checkFlowIsNotKilled()

fun checkFlowIsNotKilled(lazyMessage: () -> Any)

checkFlowPermission

fun checkFlowPermission(permissionName: String, extraAuditData: Map<String, String>)

fun close(sessions: NonEmptySet<FlowSession>)

flowStackSnapshot

fun flowStackSnapshot(): FlowStackSnapshot?

getFlowInfo

fun ~~getFlowInfo~~(otherParty: Party): FlowInfo

initiateFlow

fun initiateFlow(destination: Destination): FlowSession

fun initiateFlow(party: Party): FlowSession

persistFlowStackSnapshot

fun persistFlowStackSnapshot()

receive

inline fun <R : Any> ~~receive~~(otherParty: Party): UntrustworthyData<R>

open fun <R : Any> ~~receive~~(receiveType: Class<R>, otherParty: Party): UntrustworthyData<R>

receiveAll

open fun <R : Any> receiveAll(receiveType: Class<R>, sessions: List<FlowSession>, maySkipCheckpoint: Boolean): List<UntrustworthyData<R>>

receiveAllMap

open fun receiveAllMap(sessions: Map<FlowSession, Class<out Any>>, maySkipCheckpoint: Boolean): Map<FlowSession, UntrustworthyData<Any>>

recordAuditEvent

fun recordAuditEvent(eventType: String, comment: String, extraAuditData: Map<String, String>)

send

open fun ~~send~~(otherParty: Party, payload: Any)

sendAll

fun sendAll(payload: Any, sessions: Set<FlowSession>, maySkipCheckpoint: Boolean)

sendAllMap

fun sendAllMap(payloadsPerSession: Map<FlowSession, Any>, maySkipCheckpoint: Boolean)

sendAndReceive

inline fun <R : Any> ~~sendAndReceive~~(otherParty: Party, payload: Any): UntrustworthyData<R>

open fun <R : Any> ~~sendAndReceive~~(receiveType: Class<R>, otherParty: Party, payload: Any): UntrustworthyData<R>

subFlow

open fun <R> subFlow(subLogic: FlowLogic<R>): R

track

fun track(): DataFeed<String, String>?

trackStepsTree

fun trackStepsTree(): DataFeed<List<Pair<Int, String>>, List<Pair<Int, String>>>?

trackStepsTreeIndex

fun trackStepsTreeIndex(): DataFeed<Int, Int>?

waitForLedgerCommit

fun waitForLedgerCommit(hash: SecureHash, maySkipCheckpoint: Boolean): SignedTransaction

waitForStateConsumption

fun waitForStateConsumption(stateRefs: Set<StateRef>)

Properties

isKilled

val isKilled: Boolean

logger

val logger: Logger

ourIdentity

val ourIdentity: Party

ourIdentityAndCert

val ourIdentityAndCert: PartyAndCertificate

progressTracker

open val progressTracker: ProgressTracker?

runId

val runId: StateMachineRunId

serviceHub

val serviceHub: ServiceHub

stateMachine

var stateMachine: FlowStateMachine<*>