ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-03-17 17:45:17 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Remove redundant SessionDeliverPersistenceStrategy

Browse Source
This commit is contained in:
rick.parker 2018-05-31 09:59:42 +01:00
parent 6fef4c86d3
commit 6f30225f65
1 changed files with 0 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
node/src/main/kotlin/net/corda/node/services/statemachine/transitions/StateMachine.kt
View File

@ -15,29 +15,6 @@ import net.corda.node.services.statemachine.Event
import net.corda.node.services.statemachine.StateMachineState
import java.security.SecureRandom
/**
* Specifies what strategy to use to persist received messages.
*
* - [OnDeliver] means the received message should be persisted in a checkpoint as soon as possible. This means that the
* next time the flow enters the state machine a checkpoint will be created with the current state and the received
* message. Note that the deduplication ID of the received message will be committed together with the checkpoint.
* This means that for each [FlowSession.receive] *two* checkpoints will be created, one when receive() is called,
* and one when the message is received. It also means that internal session messages not exposed to the flow also
* create checkpoints.
* - [OnNextCommit] means that instead of creating an explicit checkpoint we wait for the next one that would happen
* anyway. During this time the message will not be acknowledged.
* Note that this also means that if the flow is completely idempotent then the message will never be persisted as
* no checkpoints are ever committed (unless the flow errors). In this case the message will be acknowledged at the
* very end of the flow.
* In general turning this on is safe and much more efficient than [OnDeliver]. However if the flow is hogging the
* fiber (for example doing some IO) then the acknowledgement window of the received message will be extended to
* an arbitrary length.
*/
enum class SessionDeliverPersistenceStrategy {
OnDeliver,
OnNextCommit
}
class StateMachine(
val id: StateMachineRunId,
val secureRandom: SecureRandom