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

PaymentFlow

@StartableByRPC
class PaymentFlow(paymentInstruction: PaymentInstruction, gateway: Party, uniquePaymentId: UUID = UUID.randomUUID(), paymentProviderId: UUID? = null) : FlowLogic<List<StateAndRef<Payment>>>

Corda flow for payment initiation

Return

List with single created Payment state

See also

Parameters

paymentInstruction

Instruction for the payment, you want to execute

gateway

Identification of the Gevamu Gateway Corda node to process payment

uniquePaymentId

Identification of the new payment; generated with UUID.randomUUID by default

Constructors

Link copied to clipboard
fun PaymentFlow(paymentInstruction: PaymentInstruction, gateway: Party, uniquePaymentId: UUID = UUID.randomUUID(), paymentProviderId: UUID? = null)

Functions

Link copied to clipboard
fun <R : Any> await(operation: FlowExternalAsyncOperation<R>): R
fun <R : Any> await(operation: FlowExternalOperation<R>): R
Link copied to clipboard
@Suspendable
open override fun call(): List<StateAndRef<Payment>>
Link copied to clipboard
fun checkFlowIsNotKilled()
fun checkFlowIsNotKilled(lazyMessage: () -> Any)
Link copied to clipboard
fun checkFlowPermission(permissionName: String, extraAuditData: Map<String, String>)
Link copied to clipboard
fun close(sessions: NonEmptySet<FlowSession>)
Link copied to clipboard
fun flowStackSnapshot(): FlowStackSnapshot?
Link copied to clipboard
fun getFlowInfo(otherParty: Party): FlowInfo
Link copied to clipboard
fun initiateFlow(destination: Destination): FlowSession
fun initiateFlow(party: Party): FlowSession
Link copied to clipboard
Link copied to clipboard
inline fun <R : Any> receive(otherParty: Party): UntrustworthyData<R>
open fun <R : Any> receive(receiveType: Class<R>, otherParty: Party): UntrustworthyData<R>
Link copied to clipboard
open fun <R : Any> receiveAll(receiveType: Class<R>, sessions: List<FlowSession>, maySkipCheckpoint: Boolean): List<UntrustworthyData<R>>
Link copied to clipboard
open fun receiveAllMap(sessions: Map<FlowSession, Class<out Any>>, maySkipCheckpoint: Boolean): Map<FlowSession, UntrustworthyData<Any>>
Link copied to clipboard
fun recordAuditEvent(eventType: String, comment: String, extraAuditData: Map<String, String>)
Link copied to clipboard
open fun send(otherParty: Party, payload: Any)
Link copied to clipboard
fun sendAll(payload: Any, sessions: Set<FlowSession>, maySkipCheckpoint: Boolean)
Link copied to clipboard
fun sendAllMap(payloadsPerSession: Map<FlowSession, Any>, maySkipCheckpoint: Boolean)
Link copied to clipboard
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>
Link copied to clipboard
open fun <R> subFlow(subLogic: FlowLogic<R>): R
Link copied to clipboard
fun track(): DataFeed<String, String>?
Link copied to clipboard
fun trackStepsTree(): DataFeed<List<Pair<Int, String>>, List<Pair<Int, String>>>?
Link copied to clipboard
fun trackStepsTreeIndex(): DataFeed<Int, Int>?
Link copied to clipboard
fun waitForLedgerCommit(hash: SecureHash, maySkipCheckpoint: Boolean): SignedTransaction
Link copied to clipboard
fun waitForStateConsumption(stateRefs: Set<StateRef>)

Properties

Link copied to clipboard
Link copied to clipboard
val logger: Logger
Link copied to clipboard
val ourIdentity: Party
Link copied to clipboard
val ourIdentityAndCert: PartyAndCertificate
Link copied to clipboard
open val progressTracker: ProgressTracker?
Link copied to clipboard
val runId: StateMachineRunId
Link copied to clipboard
val serviceHub: ServiceHub
Link copied to clipboard
var stateMachine: FlowStateMachine<*>