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

DistributedImmutableMapTest: enable copycat client connection retry to avoid race conditions

Browse Source
This commit is contained in:
Andrius Dagys 2016-12-01 13:21:25 +00:00
parent 3a52a3aa66
commit ad5d6f5cd4
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
node/src/test/kotlin/net/corda/node/services/DistributedImmutableMapTests.kt
View File

@ -2,6 +2,7 @@ package net.corda.node.services
import com.google.common.net.HostAndPort import com.google.common.net.HostAndPort
import io.atomix.catalyst.transport.Address import io.atomix.catalyst.transport.Address
import io.atomix.copycat.client.ConnectionStrategies
import io.atomix.copycat.client.CopycatClient import io.atomix.copycat.client.CopycatClient
import io.atomix.copycat.server.CopycatServer import io.atomix.copycat.server.CopycatServer
import io.atomix.copycat.server.storage.Storage import io.atomix.copycat.server.storage.Storage
@ -105,7 +106,9 @@ class DistributedImmutableMapTests {
server.bootstrap() server.bootstrap()
} }
val client = CopycatClient.builder(address).build() val client = CopycatClient.builder(address)
.withConnectionStrategy(ConnectionStrategies.EXPONENTIAL_BACKOFF)
.build()
return serverInitFuture.thenCompose { client.connect(address) }.thenApply { Member(it, server) } return serverInitFuture.thenCompose { client.connect(address) }.thenApply { Member(it, server) }
} }
} }