public class FlowStateMachineImpl<R> implements FlowStateMachine<R>
Modifier and Type | Class and Description |
---|---|
static class |
FlowStateMachineImpl.Companion |
Modifier and Type | Field and Description |
---|---|
static FlowStateMachineImpl.Companion |
Companion |
ServiceHubInternal |
serviceHub |
Constructor and Description |
---|
FlowStateMachineImpl(StateMachineRunId id,
FlowLogic<? extends R> logic,
co.paralleluniverse.fibers.FiberScheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
StateMachineRunId |
getId() |
org.slf4j.Logger |
getLogger() |
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) |
R |
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) |
void |
setServiceHub(ServiceHubInternal p) |
getId, getLogger, getResultFuture, getServiceHub, receive, send, sendAndReceive
public ServiceHubInternal serviceHub
public static FlowStateMachineImpl.Companion Companion
public FlowStateMachineImpl(StateMachineRunId id, FlowLogic<? extends R> logic, co.paralleluniverse.fibers.FiberScheduler scheduler)
public ServiceHubInternal getServiceHub()
public void setServiceHub(ServiceHubInternal p)
public org.slf4j.Logger getLogger()
public com.google.common.util.concurrent.ListenableFuture<R> getResultFuture()
This future will complete when the call method returns.
public R run()
public <T> UntrustworthyData<T> sendAndReceive(java.lang.Class<T> receiveType, Party otherParty, java.lang.Object payload, FlowLogic<?> sessionFlow)
public <T> UntrustworthyData<T> receive(java.lang.Class<T> receiveType, Party otherParty, FlowLogic<?> sessionFlow)
public StateMachineRunId getId()
public FlowLogic<R> getLogic()