From a35d835d3800b1077c906eec3c9ecd45066ad2f4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Roman=20Pla=CC=81s=CC=8Cil?= Date: Fri, 18 Aug 2017 15:07:52 +0800 Subject: [PATCH] Enable autorecovery in RAFT Copycat client Otherwise it doesn't reconnect after network issues --- .../corda/node/services/transactions/RaftUniquenessProvider.kt | 2 ++ 1 file changed, 2 insertions(+) diff --git a/node/src/main/kotlin/net/corda/node/services/transactions/RaftUniquenessProvider.kt b/node/src/main/kotlin/net/corda/node/services/transactions/RaftUniquenessProvider.kt index 3386b1a8c4..69254beeee 100644 --- a/node/src/main/kotlin/net/corda/node/services/transactions/RaftUniquenessProvider.kt +++ b/node/src/main/kotlin/net/corda/node/services/transactions/RaftUniquenessProvider.kt @@ -10,6 +10,7 @@ import io.atomix.catalyst.transport.netty.NettyTransport import io.atomix.catalyst.transport.netty.SslProtocol import io.atomix.copycat.client.ConnectionStrategies import io.atomix.copycat.client.CopycatClient +import io.atomix.copycat.client.RecoveryStrategies import io.atomix.copycat.server.CopycatServer import io.atomix.copycat.server.storage.Storage import io.atomix.copycat.server.storage.StorageLevel @@ -151,6 +152,7 @@ class RaftUniquenessProvider(services: ServiceHubInternal) : UniquenessProvider, .withTransport(transport) // TODO: use local transport for client-server communications .withConnectionStrategy(ConnectionStrategies.EXPONENTIAL_BACKOFF) .withSerializer(serializer) + .withRecoveryStrategy(RecoveryStrategies.RECOVER) .build() _clientFuture = serverFuture.thenCompose { client.connect(address) } }