net.corda.node.services.statemachine

Class FlowStateMachineImpl<R>

net.corda.node.services.statemachine.FlowStateMachineImpl<R>

All Implemented Interfaces:

FlowStateMachine<R>

public class FlowStateMachineImpl<R>
implements FlowStateMachine<R>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlowStateMachineImpl.Companion

Field Summary

Fields

Modifier and Type	Field and Description
static FlowStateMachineImpl.Companion	Companion
ServiceHubInternal	serviceHub

Constructor Summary

Constructors

Constructor and Description
FlowStateMachineImpl(StateMachineRunId id, FlowLogic<? extends R> logic, co.paralleluniverse.fibers.FiberScheduler scheduler, FlowInitiator flowInitiator)

Method Summary

Modifier and Type	Method and Description
void	checkFlowPermission(java.lang.String permissionName, java.util.Map<java.lang.String,java.lang.String> extraAuditData)
FlowInitiator	getFlowInitiator()
StateMachineRunId	getId()
org.slf4j.Logger	getLogger() Return the logger for this state machine. The logger name incorporates id and so including it in the log message is not necessary.
FlowLogic<R>	getLogic()
com.google.common.util.concurrent.ListenableFuture<R>	getResultFuture() This future will complete when the call method returns.
ServiceHubInternal	getServiceHub()
<T> UntrustworthyData<T>	receive(java.lang.Class<T> receiveType, Party otherParty, FlowLogic<?> sessionFlow)
void	recordAuditEvent(java.lang.String eventType, java.lang.String comment, java.util.Map<java.lang.String,java.lang.String> extraAuditData)
void	run()
void	send(Party otherParty, java.lang.Object payload, FlowLogic<?> sessionFlow)
<T> UntrustworthyData<T>	sendAndReceive(java.lang.Class<T> receiveType, Party otherParty, java.lang.Object payload, FlowLogic<?> sessionFlow, boolean retrySend)
void	setServiceHub(ServiceHubInternal p)
SignedTransaction	waitForLedgerCommit(SecureHash hash, FlowLogic<?> sessionFlow)

Methods inherited from interface net.corda.core.internal.FlowStateMachine

checkFlowPermission, getFlowInitiator, getId, getLogger, getResultFuture, getServiceHub, receive, recordAuditEvent, send, sendAndReceive, waitForLedgerCommit

Field Detail

serviceHub

public ServiceHubInternal serviceHub

Companion

public static FlowStateMachineImpl.Companion Companion

Constructor Detail

FlowStateMachineImpl

public FlowStateMachineImpl(StateMachineRunId id,
                            FlowLogic<? extends R> logic,
                            co.paralleluniverse.fibers.FiberScheduler scheduler,
                            FlowInitiator flowInitiator)

Method Detail

getServiceHub

public ServiceHubInternal getServiceHub()

setServiceHub

public void setServiceHub(ServiceHubInternal p)

getLogger

public org.slf4j.Logger getLogger()

Return the logger for this state machine. The logger name incorporates id and so including it in the log message is not necessary.

getResultFuture

public com.google.common.util.concurrent.ListenableFuture<R> getResultFuture()

This future will complete when the call method returns.

run

public void run()

sendAndReceive

public <T> UntrustworthyData<T> sendAndReceive(java.lang.Class<T> receiveType,
                                               Party otherParty,
                                               java.lang.Object payload,
                                               FlowLogic<?> sessionFlow,
                                               boolean retrySend)

receive

public <T> UntrustworthyData<T> receive(java.lang.Class<T> receiveType,
                                        Party otherParty,
                                        FlowLogic<?> sessionFlow)

send

public void send(Party otherParty,
                 java.lang.Object payload,
                 FlowLogic<?> sessionFlow)

waitForLedgerCommit

public SignedTransaction waitForLedgerCommit(SecureHash hash,
                                             FlowLogic<?> sessionFlow)

checkFlowPermission

public void checkFlowPermission(java.lang.String permissionName,
                                java.util.Map<java.lang.String,java.lang.String> extraAuditData)

recordAuditEvent

public void recordAuditEvent(java.lang.String eventType,
                             java.lang.String comment,
                             java.util.Map<java.lang.String,java.lang.String> extraAuditData)

getId

public StateMachineRunId getId()

getLogic

public FlowLogic<R> getLogic()

getFlowInitiator

public FlowInitiator getFlowInitiator()