From b46a837718484e4744f794d996e2b0e52ecf300f Mon Sep 17 00:00:00 2001
From: Andras Slemmer <andras.slemmer@r3.com>
Date: Mon, 11 Jun 2018 16:44:47 +0100
Subject: [PATCH] Fix MultiThreadedSMM compile error
---
.../statemachine/MultiThreadedStateMachineManager.kt | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
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 835238333a..ac1f6ffd9a 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
@@ -602,10 +602,10 @@ class MultiThreadedStateMachineManager(
/** Schedules a [FlowTimeoutException] to be fired in order to restart the flow. */
private fun scheduleTimeoutException(flow: Flow, retryCount: Int): ScheduledFuture<*> {
- return with(serviceHub.configuration.p2pMessagingRetry) {
- val timeoutDelaySeconds = messageRedeliveryDelay.seconds * Math.pow(backoffBase, retryCount.toDouble()).toLong()
+ return with(serviceHub.configuration.flowTimeout) {
+ val timeoutDelaySeconds = timeout.seconds * Math.pow(backoffBase, retryCount.toDouble()).toLong()
timeoutScheduler.schedule({
- val event = Event.Error(FlowTimeoutException(maxRetryCount))
+ val event = Event.Error(FlowTimeoutException(maxRestartCount))
flow.fiber.scheduleEvent(event)
}, timeoutDelaySeconds, TimeUnit.SECONDS)
}