diff --git a/node/src/main/kotlin/net/corda/node/services/statemachine/MultiThreadedStateMachineManager.kt b/node/src/main/kotlin/net/corda/node/services/statemachine/MultiThreadedStateMachineManager.kt index c746a63356..8c1a1e8526 100644 --- a/node/src/main/kotlin/net/corda/node/services/statemachine/MultiThreadedStateMachineManager.kt +++ b/node/src/main/kotlin/net/corda/node/services/statemachine/MultiThreadedStateMachineManager.kt @@ -364,8 +364,7 @@ class MultiThreadedStateMachineManager( checkpoint = checkpoint, initialDeduplicationHandler = null, isAnyCheckpointPersisted = true, - isStartIdempotent = false, - senderUUID = null + isStartIdempotent = false ) } else { // Just flow initiation message @@ -664,8 +663,7 @@ class MultiThreadedStateMachineManager( checkpoint: Checkpoint, isAnyCheckpointPersisted: Boolean, isStartIdempotent: Boolean, - initialDeduplicationHandler: DeduplicationHandler?, - senderUUID: String? = ourSenderUUID + initialDeduplicationHandler: DeduplicationHandler? ): Flow { val flowState = checkpoint.flowState val resultFuture = openFuture() @@ -681,7 +679,7 @@ class MultiThreadedStateMachineManager( isStartIdempotent = isStartIdempotent, isRemoved = false, flowLogic = logic, - senderUUID = senderUUID + senderUUID = null ) val fiber = FlowStateMachineImpl(id, logic, scheduler) fiber.transientValues = TransientReference(createTransientValues(id, resultFuture)) @@ -700,7 +698,7 @@ class MultiThreadedStateMachineManager( isStartIdempotent = isStartIdempotent, isRemoved = false, flowLogic = fiber.logic, - senderUUID = senderUUID + senderUUID = null ) fiber.transientValues = TransientReference(createTransientValues(id, resultFuture)) fiber.transientState = TransientReference(state)